Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159865180
--- 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 --
I can not find usages of this in this commit. Is it used here somehow? If
not, please remove it/extract to separate commit/move to appropriate commit.
---
