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
prepare
void prepare(java.util.Map conf,
TopologyContext context,
BatchOutputCollector collector,
T id)
execute
void execute(Tuple tuple)
finishBatch
void finishBatch()