public class TestConfBolt extends BaseBasicBolt
| Constructor and Description |
|---|
TestConfBolt() |
TestConfBolt(Map<String,Object> componentConf) |
| 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.
|
Map<String,Object> |
getComponentConfiguration()
Declare configuration specific to this component.
|
void |
prepare(Map<String,Object> conf,
TopologyContext context) |
cleanuppublic void prepare(Map<String,Object> conf, TopologyContext context)
prepare in interface IBasicBoltprepare in class BaseBasicBoltpublic void declareOutputFields(OutputFieldsDeclarer declarer)
IComponentDeclare 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 streampublic void execute(Tuple input, BasicOutputCollector collector)
IBasicBoltProcess 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 Map<String,Object> getComponentConfiguration()
IComponentDeclare configuration specific to this component. Only a subset of the “topology.*” configs can be overridden. The component configuration can be further overridden when constructing the topology using TopologyBuilder
getComponentConfiguration in interface IComponentgetComponentConfiguration in class BaseComponentCopyright © 2021 The Apache Software Foundation. All rights reserved.