backtype.storm.coordination
Interface IBatchBolt<T>

All Superinterfaces:

IComponent, java.io.Serializable

All Known Implementing Classes:

BaseBatchBolt, BaseTransactionalBolt, CountingBatchBolt, CountingCommitBolt, KeyedCountingBatchBolt, KeyedCountingCommitterBolt, KeyedSummingBatchBolt

public interface IBatchBolt<T>
extends java.io.Serializable, IComponent

Method Summary

void	execute(Tuple tuple)
void	finishBatch()
void	prepare(java.util.Map conf, TopologyContext context, BatchOutputCollector collector, T id)

Methods inherited from interface backtype.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Detail

prepare

void prepare(java.util.Map conf,
             TopologyContext context,
             BatchOutputCollector collector,
             T id)

execute

void execute(Tuple tuple)

finishBatch

void finishBatch()