Class StateTableByKeyGroupReaders


  • @Internal
    public class StateTableByKeyGroupReaders
    extends Object
    This class provides a static factory method to create different implementations of StateSnapshotKeyGroupReader depending on the provided serialization format version.

    The implementations are also located here as inner classes.

    • Constructor Detail

      • StateTableByKeyGroupReaders

        public StateTableByKeyGroupReaders()
    • 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 - the StateTable into which de-serialized mappings are inserted.
        version - version for the de-serialization algorithm.
        Returns:
        the appropriate reader.