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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
initState(KeyValueState<K,V> keyValueState)
Initialize the state of the processor with the givenKeyValueState
.
-
-
-
Method Detail
-
initState
void initState(KeyValueState<K,V> keyValueState)
Initialize the state of the processor with the givenKeyValueState
.- Parameters:
keyValueState
- the key-value state
-
-