storm.trident.spout
Class TridentSpoutCoordinator
java.lang.Object
storm.trident.spout.TridentSpoutCoordinator
- All Implemented Interfaces:
- IBasicBolt, IComponent, java.io.Serializable
public class TridentSpoutCoordinator
- extends java.lang.Object
- implements IBasicBolt
- See Also:
- Serialized Form
Field Summary |
static Logger |
LOG
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LOG
public static final Logger LOG
TridentSpoutCoordinator
public TridentSpoutCoordinator(java.lang.String id,
ITridentSpout spout)
prepare
public void prepare(java.util.Map conf,
TopologyContext context)
- Specified by:
prepare
in interface IBasicBolt
execute
public void execute(Tuple tuple,
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.
- Specified by:
execute
in interface IBasicBolt
cleanup
public void cleanup()
- Specified by:
cleanup
in interface IBasicBolt
declareOutputFields
public void declareOutputFields(OutputFieldsDeclarer declarer)
- Description copied from interface:
IComponent
- Declare the output schema for all the streams of this topology.
- Specified by:
declareOutputFields
in interface IComponent
- Parameters:
declarer
- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
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