@Test public void testSnapshotBeforeSpill() throws Exception { Map<Integer, Tuple2<Integer, Integer>> expectedData = genData(0, 10000); storeData(expectedData); verifyData(expectedData); Map<Integer, Tuple2<Integer, Integer>> snapshotData1 = new HashMap<>(expectedData); SpillableStateTableSnapshot snapshot1 = stateTable.stateSnapshot(); stateTable.spillState(0); stateTable.spillState(3); Map<Integer, Tuple2<Integer, Integer>> incData = genData(10000, 20000); storeData(incData); expectedData.putAll(incData); verifyData(expectedData); Map<Integer, Tuple2<Integer, Integer>> snapshotData2 = new HashMap<>(expectedData); SpillableStateTableSnapshot snapshot2 = stateTable.stateSnapshot(); verifySnapshot(snapshot1, snapshotData1); verifySnapshot(snapshot2, snapshotData2); }
public abstract void spillState(int keyGroupIndex);
SpillableStateTable extends StateTable<K, N, S> implements Closeable { public abstract void spillState(int keyGroupIndex); }
SpillableStateTable extends StateTable<K, N, S> implements Closeable { public abstract void spillState(int keyGroupIndex); SpillableStateTable(
		InternalKeyContext<K> keyContext,
		RegisteredKeyValueStateBackendMetaInfo<N, S> metaInfo,
		TypeSerializer<K> keySerializer); }
SpillableStateTable extends StateTable<K, N, S> implements Closeable { public abstract void spillState(int keyGroupIndex); SpillableStateTable(
		InternalKeyContext<K> keyContext,
		RegisteredKeyValueStateBackendMetaInfo<N, S> metaInfo,
		TypeSerializer<K> keySerializer); abstract void updateStateEstimate(N namespace, S state); abstract long getStateEstimatedSize(boolean force); abstract void spillState(int keyGroupIndex); abstract void loadState(int keyGroupIndex); abstract Iterator<SpillableStateTable.StateMapMeta> stateMapIterator(); }
SpillableStateTable extends StateTable<K, N, S> implements Closeable { public abstract void spillState(int keyGroupIndex); SpillableStateTable(
		InternalKeyContext<K> keyContext,
		RegisteredKeyValueStateBackendMetaInfo<N, S> metaInfo,
		TypeSerializer<K> keySerializer); abstract void updateStateEstimate(N namespace, S state); abstract long getStateEstimatedSize(boolean force); abstract void spillState(int keyGroupIndex); abstract void loadState(int keyGroupIndex); abstract Iterator<SpillableStateTable.StateMapMeta> stateMapIterator();  }