Interface ITridentBatchBolt
- All Superinterfaces:
IComponent,Serializable
- All Known Implementing Classes:
SubtopologyBolt,TridentSpoutExecutor
-
Method Summary
Modifier and TypeMethodDescriptionvoidcleanup()voidvoidfinishBatch(BatchInfo batchInfo) initBatchState(String batchGroup, Object batchId) voidprepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector) Methods inherited from interface org.apache.storm.topology.IComponent
declareOutputFields, getComponentConfiguration
-
Method Details
-
prepare
-
execute
-
finishBatch
-
initBatchState
-
cleanup
void cleanup()
-