Interface IStatefulBolt<T extends State>

All Superinterfaces:
IComponent, IStatefulComponent<T>, Serializable
All Known Implementing Classes:
BaseStatefulBolt, PersistentWindowedBoltExecutor, StatefulWindowedBoltExecutor, StatefulWordCounter

public interface IStatefulBolt<T extends State> extends IStatefulComponent<T>
A bolt abstraction for supporting stateful computation. The state of the bolt is periodically checkpointed.

The framework provides at-least once guarantee for the state updates. The stateful bolts are expected to anchor the tuples while emitting and ack the input tuples once its processed.