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 SummaryModifier 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.IComponentdeclareOutputFields, getComponentConfiguration
- 
Method Details- 
prepareThis is similar to theIBolt.prepare(Map, TopologyContext, OutputCollector)except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow.
- 
executeProcess the tuple window and optionally emit new tuples based on the tuples in the input window.
- 
cleanupvoid cleanup()
- 
getTimestampExtractorTimestampExtractor getTimestampExtractor()Return aTimestampExtractorfor extracting timestamps from a tuple for event time based processing, or null for processing time.- Returns:
- the timestamp extractor
 
 
-