flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject [6/8] flink git commit: [runtime] Remove old unused classes
Date Tue, 07 Apr 2015 16:32:48 GMT
[runtime] Remove old unused classes


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09bd1f89
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/09bd1f89
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/09bd1f89

Branch: refs/heads/release-0.9.0-milestone-1
Commit: 09bd1f89f4fc70318250463e653cf862d07c1b28
Parents: 4363f98
Author: Stephan Ewen <sewen@apache.org>
Authored: Tue Apr 7 11:01:58 2015 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Tue Apr 7 18:13:00 2015 +0200

----------------------------------------------------------------------
 .../apache/flink/runtime/util/EnumUtils.java    | 79 --------------------
 .../runtime/util/UnmodifiableIterator.java      | 72 ------------------
 2 files changed, 151 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/09bd1f89/flink-runtime/src/main/java/org/apache/flink/runtime/util/EnumUtils.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/EnumUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/util/EnumUtils.java
deleted file mode 100644
index 3512e13..0000000
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/util/EnumUtils.java
+++ /dev/null
@@ -1,79 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.runtime.util;
-
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
-
-import org.apache.flink.types.StringValue;
-
-/**
- * Auxiliary class to (de)serialize enumeration values.
- */
-public final class EnumUtils {
-
-	/**
-	 * Private constructor to overwrite public one.
-	 */
-	private EnumUtils() {
-	}
-
-	/**
-	 * Reads a value from the given enumeration from the specified input stream.
-	 * 
-	 * @param <T>
-	 *        the type of the enumeration
-	 * @param in
-	 *        the input stream to read from
-	 * @param enumType
-	 *        the class of the enumeration
-	 * @return the value of the given enumeration read from the input stream
-	 * @throws IOException
-	 *         thrown if any error occurred while reading data from the stream
-	 */
-	public static <T extends Enum<T>> T readEnum(final DataInput in, final Class<T>
enumType) throws IOException {
-
-		if (!in.readBoolean()) {
-			return null;
-		}
-
-		return T.valueOf(enumType, StringValue.readString(in));
-	}
-
-	/**
-	 * Writes a value of an enumeration to the given output stream.
-	 * 
-	 * @param out
-	 *        the output stream to write to
-	 * @param enumVal
-	 *        the value of a enumeration to be written to the output stream
-	 * @throws IOException
-	 *         thrown if any error occurred while writing data to the stream
-	 */
-	public static void writeEnum(final DataOutput out, final Enum<?> enumVal) throws IOException
{
-
-		if (enumVal == null) {
-			out.writeBoolean(false);
-		} else {
-			out.writeBoolean(true);
-			StringValue.writeString(enumVal.name(), out);
-		}
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/09bd1f89/flink-runtime/src/main/java/org/apache/flink/runtime/util/UnmodifiableIterator.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/UnmodifiableIterator.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/util/UnmodifiableIterator.java
deleted file mode 100644
index caa36c5..0000000
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/util/UnmodifiableIterator.java
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-package org.apache.flink.runtime.util;
-
-import java.util.Iterator;
-
-/**
- * An auxiliary implementation of an iterator which protects the underlying collection from
being modified. As a result,
- * calling the remove method on this iterator will result in an {@link UnsupportedOperationException}.
- * <p>
- * This class is thread-safe.
- * 
- * @param <T>
- *        the type of the encapsulated iterator
- */
-public final class UnmodifiableIterator<T> implements Iterator<T> {
-
-	/**
-	 * The encapsulated iterator.
-	 */
-	private final Iterator<T> encapsulatedIterator;
-
-	/**
-	 * Constructs a new unmodifiable iterator.
-	 * 
-	 * @param encapsulatedIterator
-	 *        the encapsulated iterator
-	 */
-	public UnmodifiableIterator(final Iterator<T> encapsulatedIterator) {
-
-		this.encapsulatedIterator = encapsulatedIterator;
-	}
-
-
-	@Override
-	public boolean hasNext() {
-
-		return this.encapsulatedIterator.hasNext();
-	}
-
-
-	@Override
-	public T next() {
-
-		return this.encapsulatedIterator.next();
-	}
-
-
-	@Override
-	public void remove() {
-
-		throw new UnsupportedOperationException("Calling the remove method on this iterator is
not allowed");
-	}
-
-}


Mime
View raw message