Package org.apache.storm.flux.examples
Class TestWindowBolt
java.lang.Object
org.apache.storm.topology.base.BaseWindowedBolt
org.apache.storm.flux.examples.TestWindowBolt
- All Implemented Interfaces:
Serializable,IComponent,IWindowedBolt
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.storm.topology.base.BaseWindowedBolt
BaseWindowedBolt.Count, BaseWindowedBolt.Duration -
Field Summary
Fields inherited from class org.apache.storm.topology.base.BaseWindowedBolt
timestampExtractor, windowConfiguration -
Constructor Summary
Constructors -
Method Summary
Modifier 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.BaseWindowedBolt
cleanup, getComponentConfiguration, getTimestampExtractor, withLag, withLateTupleStream, withTimestampExtractor, withTimestampField, withTumblingWindow, withTumblingWindow, withWatermarkInterval, withWindow, withWindow, withWindow, withWindow, withWindow, withWindow
-
Constructor Details
-
TestWindowBolt
public TestWindowBolt()
-
-
Method Details
-
prepare
public 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 interfaceIWindowedBolt- Overrides:
preparein classBaseWindowedBolt
-
execute
Description copied from interface:IWindowedBoltProcess the tuple window and optionally emit new tuples based on the tuples in the input window. -
declareOutputFields
Description copied from interface:IComponentDeclare the output schema for all the streams of this topology.- Specified by:
declareOutputFieldsin interfaceIComponent- Overrides:
declareOutputFieldsin classBaseWindowedBolt- Parameters:
declarer- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
-