Package 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
    Description
    void
    initState(KeyValueState<K,V> keyValueState)
    Initialize the state of the processor with the given KeyValueState.

  • Method Details

    • initState

      void initState(KeyValueState<K,V> keyValueState)
      Initialize the state of the processor with the given KeyValueState.
      Parameters:
      keyValueState - the key-value state