[FLINK-21206] Implement HeapKeyValueStateIterator

tongcheng-elong · Feb 22, 2021 · 5010d2a · 5010d2a
1 parent d84e7ca
commit 5010d2a
Show file tree

Hide file tree

Showing 3 changed files with 467 additions and 23 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyValueStateIterator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyValueStateIterator.java
@@ -18,6 +18,8 @@
 
 package org.apache.flink.runtime.state;
 
+import java.io.IOException;
+
 /**
  * Iterator that over all key-value state entries in a {@link KeyedStateBackend}. For use during
  * snapshotting.
@@ -31,7 +33,7 @@ public interface KeyValueStateIterator extends AutoCloseable {
  * Advances the iterator. Should only be called if {@link #isValid()} returned true. Valid flag
  * can only change after calling {@link #next()}.
  */
- void next();
+ void next() throws IOException;
 
  /** Returns the key-group for the current key. */
  int keyGroup();