Package org.apache.storm.starter
Class ReachTopology.CountAggregator
java.lang.Object
org.apache.storm.topology.base.BaseComponent
org.apache.storm.topology.base.BaseBatchBolt<Object>
org.apache.storm.starter.ReachTopology.CountAggregator
- All Implemented Interfaces:
- Serializable,- IBatchBolt<Object>,- IComponent
- Enclosing class:
- ReachTopology
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.voidvoidvoidprepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector, Object id) Methods inherited from class org.apache.storm.topology.base.BaseComponentgetComponentConfigurationMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.topology.IComponentgetComponentConfiguration
- 
Constructor Details- 
CountAggregatorpublic CountAggregator()
 
- 
- 
Method Details- 
preparepublic void prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector, Object id) 
- 
execute
- 
finishBatchpublic void finishBatch()
- 
declareOutputFieldsDescription copied from interface:IComponentDeclare the output schema for all the streams of this topology.- Parameters:
- declarer- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
 
 
-