Interface StatefulProcessor<K,​V>

  • Type Parameters:
    K - the key type
    V - the value type
    All Known Implementing Classes:
    StateQueryProcessor, UpdateStateByKeyProcessor

    public interface StatefulProcessor<K,​V>
    Top level interface for processors that does stateful processing.
    • Method Detail

      • initState

        void initState​(KeyValueState<K,​V> keyValueState)
        Initialize the state of the processor with the given KeyValueState.
        Parameters:
        keyValueState - the key-value state