Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r162582925
--- Diff:
flink-core/src/main/java/org/apache/flink/util/CloseableIterator.java ---
@@ -18,11 +18,38 @@
package org.apache.flink.util;
-import org.apache.flink.annotation.Internal;
+import java.io.Closeable;
+import java.io.IOException;
+import java.util.Iterator;
/**
- * Tagging interface for migration related classes.
+ * This interface represents an iterator that is also closeable.
+ *
+ * @param <T> type of the iterated objects.
*/
-@Internal
-public interface Migration {
+public interface CloseableIterator<T> extends Iterator<T>, Closeable {
--- End diff --
ð
---
