org.apache.storm.topology

Interface IStatefulBolt<T extends State>

All Superinterfaces:

IComponent, IStatefulComponent<T>, Serializable

All Known Implementing Classes:

BaseStatefulBolt, StatefulWindowedBoltExecutor

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(Map stormConf, 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(Map stormConf,
             TopologyContext context,
             OutputCollector collector)

See Also:

IBolt.prepare(Map, TopologyContext, OutputCollector)

execute

void execute(Tuple input)

See Also:

IBolt.execute(Tuple)

cleanup

void cleanup()

See Also:

IBolt.cleanup()