backtype.storm.testing
Class TestConfBolt
java.lang.Object
backtype.storm.topology.base.BaseComponent
backtype.storm.topology.base.BaseBasicBolt
backtype.storm.testing.TestConfBolt
- All Implemented Interfaces:
- IBasicBolt, IComponent, java.io.Serializable
public class TestConfBolt
- extends BaseBasicBolt
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TestConfBolt
public TestConfBolt()
TestConfBolt
public TestConfBolt(java.util.Map<java.lang.String,java.lang.Object> componentConf)
prepare
public void prepare(java.util.Map conf,
TopologyContext context)
- Specified by:
prepare
in interface IBasicBolt
- Overrides:
prepare
in class BaseBasicBolt
declareOutputFields
public void declareOutputFields(OutputFieldsDeclarer declarer)
- Description copied from interface:
IComponent
- Declare the output schema for all the streams of this topology.
- Parameters:
declarer
- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
execute
public void execute(Tuple input,
BasicOutputCollector collector)
- Description copied from interface:
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.
getComponentConfiguration
public java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
- Description copied from interface:
IComponent
- Declare 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
- Specified by:
getComponentConfiguration
in interface IComponent
- Overrides:
getComponentConfiguration
in class BaseComponent