public class LambdaBiConsumerBolt extends BaseBasicBolt
Constructor and Description |
---|
LambdaBiConsumerBolt(SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer,
String[] fields) |
Modifier and Type | Method and Description |
---|---|
void |
declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
execute(Tuple input,
BasicOutputCollector collector)
Process the input tuple and optionally emit new tuples based on the input tuple.
|
cleanup, prepare
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentConfiguration
public LambdaBiConsumerBolt(SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, String[] fields)
public void execute(Tuple input, BasicOutputCollector collector)
IBasicBolt
Process the input tuple and optionally emit new tuples based on the input tuple.
All acking is managed for you. Throw a FailedException if you want to fail the tuple.
public void declareOutputFields(OutputFieldsDeclarer declarer)
IComponent
Declare the output schema for all the streams of this topology.
declarer
- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streamCopyright © 2022 The Apache Software Foundation. All rights reserved.