Package org.apache.storm.topology
Interface IWindowedBolt
- All Superinterfaces:
IComponent,Serializable
- All Known Subinterfaces:
IStatefulWindowedBolt<T>
- All Known Implementing Classes:
BaseStatefulWindowedBolt,BaseWindowedBolt,JoinBolt,SlidingWindowSumBolt,TestWindowBolt,TimeDataVerificationBolt,VerificationBolt
A bolt abstraction for supporting time and count based sliding & tumbling windows.
-
Method Summary
Modifier and TypeMethodDescriptionvoidcleanup()voidexecute(TupleWindow inputWindow) Process the tuple window and optionally emit new tuples based on the tuples in the input window.Return aTimestampExtractorfor extracting timestamps from a tuple for event time based processing, or null for processing time.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 interface org.apache.storm.topology.IComponent
declareOutputFields, getComponentConfiguration
-
Method Details
-
prepare
This is similar to theIBolt.prepare(Map, TopologyContext, OutputCollector)except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow. -
execute
Process the tuple window and optionally emit new tuples based on the tuples in the input window. -
cleanup
void cleanup() -
getTimestampExtractor
TimestampExtractor getTimestampExtractor()Return aTimestampExtractorfor extracting timestamps from a tuple for event time based processing, or null for processing time.- Returns:
- the timestamp extractor
-