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 TypeMethodDescriptionvoid
void
void
prepare
(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()
-