@Test public void testSpill() { Map<Integer, Tuple2<Integer, Integer>> expectedData = genData(0, 10000); storeData(expectedData); verifyData(expectedData); for (int i = 0; i < numberOfKeyGroups; i++) { assertTrue(stateTable.getMapForKeyGroup(i) instanceof CopyOnWriteStateMap); } for (int i = 0; i < numberOfKeyGroups; i++) { stateTable.spillState(i); assertTrue(stateTable.getMapForKeyGroup(i) instanceof CopyOnWriteSkipListStateMap); Map<Integer, Tuple2<Integer, Integer>> data = genData(10000 + i * 1000, 10000 + (i + 1) * 1000); storeData(data); expectedData.putAll(data); verifyData(expectedData); } }
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();  }