Package org.apache.storm.coordination

Interface IBatchBolt<T>

All Superinterfaces:

IComponent, Serializable

All Known Implementing Classes:

BaseBatchBolt, ReachTopology.CountAggregator, ReachTopology.PartialUniquer

public interface IBatchBolt<T>
extends Serializable, IComponent

Method Summary

Modifier and Type	Method	Description
void	execute(Tuple tuple)
void	finishBatch()
void	prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, T id)

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

declareOutputFields, getComponentConfiguration

Method Details

prepare

void prepare(Map<String,Object> conf,
 TopologyContext context,
 BatchOutputCollector collector,
 T id)

execute

void execute(Tuple tuple)

finishBatch

void finishBatch()