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 TypeMethodDescriptionvoid
cleanup()
void
execute
(TupleWindow inputWindow) Process the tuple window and optionally emit new tuples based on the tuples in the input window.Return aTimestampExtractor
for extracting timestamps from a tuple for event time based processing, or null for processing time.void
prepare
(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 aTimestampExtractor
for extracting timestamps from a tuple for event time based processing, or null for processing time.- Returns:
- the timestamp extractor
-