Package org.apache.storm.coordination
Interface IBatchBolt<T>
- All Superinterfaces:
IComponent,Serializable
- All Known Implementing Classes:
BaseBatchBolt,ReachTopology.CountAggregator,ReachTopology.PartialUniquer
-
Method Summary
Modifier and TypeMethodDescriptionvoidvoidvoidprepare(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
-
finishBatch
void finishBatch()
-