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 TypeMethodDescriptionvoid
initState
(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
-