public class TestWindowBolt extends BaseWindowedBolt
BaseWindowedBolt.Count, BaseWindowedBolt.DurationtimestampExtractor, windowConfiguration| Constructor and Description |
|---|
TestWindowBolt() |
| Modifier and Type | Method and Description |
|---|---|
void |
declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
execute(TupleWindow inputWindow)
Process the tuple window and optionally emit new tuples based on the tuples in the input window.
|
void |
prepare(Map<String,Object> topoConf,
TopologyContext context,
OutputCollector collector)
This is similar to the
IBolt.prepare(Map, TopologyContext, OutputCollector) except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow. |
cleanup, getComponentConfiguration, getTimestampExtractor, withLag, withLateTupleStream, withTimestampExtractor, withTimestampField, withTumblingWindow, withTumblingWindow, withWatermarkInterval, withWindow, withWindow, withWindow, withWindow, withWindow, withWindowpublic void prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
IWindowedBoltThis is similar to the IBolt.prepare(Map, TopologyContext, OutputCollector) except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow.
prepare in interface IWindowedBoltprepare in class BaseWindowedBoltpublic void execute(TupleWindow inputWindow)
IWindowedBoltProcess the tuple window and optionally emit new tuples based on the tuples in the input window.
public void declareOutputFields(OutputFieldsDeclarer declarer)
IComponentDeclare the output schema for all the streams of this topology.
declareOutputFields in interface IComponentdeclareOutputFields in class BaseWindowedBoltdeclarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streamCopyright © 2021 The Apache Software Foundation. All rights reserved.