backtype.storm.testing
Class BatchRepeatA

java.lang.Object
  extended by backtype.storm.topology.base.BaseComponent
      extended by backtype.storm.topology.base.BaseBasicBolt
          extended by backtype.storm.testing.BatchRepeatA
All Implemented Interfaces:
IBasicBolt, IComponent, java.io.Serializable

public class BatchRepeatA
extends BaseBasicBolt

See Also:
Serialized Form

Constructor Summary
BatchRepeatA()
           
 
Method Summary
 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.
 
Methods inherited from class backtype.storm.topology.base.BaseBasicBolt
cleanup, prepare
 
Methods inherited from class backtype.storm.topology.base.BaseComponent
getComponentConfiguration
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface backtype.storm.topology.IComponent
getComponentConfiguration
 

Constructor Detail

BatchRepeatA

public BatchRepeatA()
Method Detail

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.


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