Package org.apache.storm.topology
Interface IStatefulBolt<T extends State>
- All Superinterfaces:
- IComponent,- IStatefulComponent<T>,- Serializable
- All Known Implementing Classes:
- BaseStatefulBolt,- PersistentWindowedBoltExecutor,- StatefulWindowedBoltExecutor,- StatefulWordCounter
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.
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()Analogue to bolt function.voidAnalogue to bolt function.voidprepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) Analogue to bolt function.Methods inherited from interface org.apache.storm.topology.IComponentdeclareOutputFields, getComponentConfigurationMethods inherited from interface org.apache.storm.topology.IStatefulComponentinitState, preCommit, prePrepare, preRollback
- 
Method Details- 
prepareAnalogue to bolt function.
- 
executeAnalogue to bolt function.- See Also:
 
- 
cleanupvoid cleanup()Analogue to bolt function.- See Also:
 
 
-