org.apache.storm.topology

Interface IStatefulBolt<T extends State>

All Superinterfaces:

IComponent, IStatefulComponent<T>, java.io.Serializable

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.

Method Summary

Modifier and Type	Method and Description
void	cleanup()
void	execute(Tuple input)
void	prepare(java.util.Map<java.lang.String,java.lang.Object> topoConf, TopologyContext context, OutputCollector collector)

Methods inherited from interface org.apache.storm.topology.IStatefulComponent

initState, preCommit, prePrepare, preRollback

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Detail

prepare

void prepare(java.util.Map<java.lang.String,java.lang.Object> topoConf,
             TopologyContext context,
             OutputCollector collector)

execute

void execute(Tuple input)

cleanup

void cleanup()