public interface StatefulProcessor<K,V>
Top level interface for processors that does stateful processing.
| Modifier and Type | Method and Description |
|---|---|
void |
initState(KeyValueState<K,V> keyValueState)
Initialize the state of the processor with the given
KeyValueState. |
void initState(KeyValueState<K,V> keyValueState)
Initialize the state of the processor with the given KeyValueState.
keyValueState - the key-value stateCopyright © 2021 The Apache Software Foundation. All rights reserved.