Package org.apache.storm.starter.bolt
Class SlidingWindowSumBolt
java.lang.Object
org.apache.storm.topology.base.BaseWindowedBolt
org.apache.storm.starter.bolt.SlidingWindowSumBolt
- All Implemented Interfaces:
- Serializable,- IComponent,- IWindowedBolt
Computes sliding window sum.
- See Also:
- 
Nested Class SummaryNested classes/interfaces inherited from class org.apache.storm.topology.base.BaseWindowedBoltBaseWindowedBolt.Count, BaseWindowedBolt.Duration
- 
Field SummaryFields inherited from class org.apache.storm.topology.base.BaseWindowedBolttimestampExtractor, windowConfiguration
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.voidexecute(TupleWindow inputWindow) Process the tuple window and optionally emit new tuples based on the tuples in the input window.voidprepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) This is similar to theIBolt.prepare(Map, TopologyContext, OutputCollector)except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow.Methods inherited from class org.apache.storm.topology.base.BaseWindowedBoltcleanup, getComponentConfiguration, getTimestampExtractor, withLag, withLateTupleStream, withTimestampExtractor, withTimestampField, withTumblingWindow, withTumblingWindow, withWatermarkInterval, withWindow, withWindow, withWindow, withWindow, withWindow, withWindow
- 
Constructor Details- 
SlidingWindowSumBoltpublic SlidingWindowSumBolt()
 
- 
- 
Method Details- 
preparepublic void prepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) Description copied from interface:IWindowedBoltThis is similar to theIBolt.prepare(Map, TopologyContext, OutputCollector)except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow.- Specified by:
- preparein interface- IWindowedBolt
- Overrides:
- preparein class- BaseWindowedBolt
 
- 
executeDescription copied from interface:IWindowedBoltProcess the tuple window and optionally emit new tuples based on the tuples in the input window.
- 
declareOutputFieldsDescription copied from interface:IComponentDeclare the output schema for all the streams of this topology.- Specified by:
- declareOutputFieldsin interface- IComponent
- Overrides:
- declareOutputFieldsin class- BaseWindowedBolt
- Parameters:
- declarer- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
 
 
-