You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/04/07 18:32:48 UTC
[6/8] flink git commit: [runtime] Remove old unused classes
[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 <se...@apache.org>
Authored: Tue Apr 7 11:01:58 2015 +0200
Committer: Stephan Ewen <se...@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");
- }
-
-}