storm.trident.topology
Interface ITridentBatchBolt
- All Superinterfaces:
- IComponent, java.io.Serializable
- All Known Implementing Classes:
- SubtopologyBolt, TridentSpoutExecutor
public interface ITridentBatchBolt
- extends IComponent
prepare
void prepare(java.util.Map conf,
TopologyContext context,
BatchOutputCollector collector)
execute
void execute(BatchInfo batchInfo,
Tuple tuple)
finishBatch
void finishBatch(BatchInfo batchInfo)
initBatchState
java.lang.Object initBatchState(java.lang.String batchGroup,
java.lang.Object batchId)
cleanup
void cleanup()