Package org.apache.storm.state
-
Interface Summary Interface Description IStateSpout IStateSpoutOutputCollector ISubscribedState ISynchronizeOutputCollector KeyValueState<K,V> A state that supports key-value mappings.Serializer<T> Interface to be implemented for serlializing and de-serializing the state.State The state of the component that is either managed by the framework (e.g in case ofIStatefulBolt
) or managed by the the individual components themselves.StateEncoder<K,V,KENCODEDT,VENCODEDT> The interface of State Encoder.StateProvider Used by theStateFactory
to create a new state instances. -
Class Summary Class Description BaseBinaryStateIterator<K,V> Base implementation of iterator overKeyValueState
which encoded types of key and value are both binary type.BaseStateIterator<K,V,KENCODEDT,VENCODEDT> Base implementation of iterator overKeyValueState
.DefaultStateEncoder<K,V> Default state encoder class for encoding/decoding key values.DefaultStateSerializer<T> A default implementation that uses Kryo to serialize and de-serialize the state.InMemoryKeyValueState<K,V> An in-memory implementation of theState
.InMemoryKeyValueStateProvider ProvidesInMemoryKeyValueState
.StateFactory A factory for creatingState
instances.StateSpoutOutputCollector SynchronizeOutputCollector