Interface StatefulProcessor<K,V>
- Type Parameters:
K- the key typeV- the value type
- All Known Implementing Classes:
StateQueryProcessor,UpdateStateByKeyProcessor
public interface StatefulProcessor<K,V>
Top level interface for processors that does stateful processing.
-
Method Summary
Modifier and TypeMethodDescriptionvoidinitState(KeyValueState<K, V> keyValueState) Initialize the state of the processor with the givenKeyValueState.
-
Method Details
-
initState
Initialize the state of the processor with the givenKeyValueState.- Parameters:
keyValueState- the key-value state
-