org.apache.storm.streams.processors

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 Summary

Modifier and Type	Method and Description
void	initState(KeyValueState<K,V> keyValueState) Initialize the state of the processor with the given KeyValueState.

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