Class StateTableByKeyGroupReaders
- java.lang.Object
-
- org.apache.flink.runtime.state.heap.StateTableByKeyGroupReaders
-
@Internal public class StateTableByKeyGroupReaders extends Object
This class provides a static factory method to create different implementations ofStateSnapshotKeyGroupReader
depending on the provided serialization format version.The implementations are also located here as inner classes.
-
-
Constructor Summary
Constructors Constructor Description StateTableByKeyGroupReaders()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <K,N,S>
StateSnapshotKeyGroupReaderreaderForVersion(StateTable<K,N,S> stateTable, int version)
Creates a new StateTableByKeyGroupReader that inserts de-serialized mappings into the given table, using the de-serialization algorithm that matches the given version.
-
-
-
Method Detail
-
readerForVersion
public static <K,N,S> StateSnapshotKeyGroupReader readerForVersion(StateTable<K,N,S> stateTable, int version)
Creates a new StateTableByKeyGroupReader that inserts de-serialized mappings into the given table, using the de-serialization algorithm that matches the given version.- Type Parameters:
K
- type of key.N
- type of namespace.S
- type of state.- Parameters:
stateTable
- theStateTable
into which de-serialized mappings are inserted.version
- version for the de-serialization algorithm.- Returns:
- the appropriate reader.
-
-