backtype.storm.testing
Class KeyedSummingBatchBolt

java.lang.Object
  extended by backtype.storm.topology.base.BaseComponent
      extended by backtype.storm.topology.base.BaseBatchBolt
          extended by backtype.storm.testing.KeyedSummingBatchBolt
All Implemented Interfaces:
IBatchBolt, IComponent, java.io.Serializable

public class KeyedSummingBatchBolt
extends BaseBatchBolt

See Also:
Serialized Form

Constructor Summary
KeyedSummingBatchBolt()
           
 
Method Summary
 void declareOutputFields(OutputFieldsDeclarer declarer)
          Declare the output schema for all the streams of this topology.
 void execute(Tuple tuple)
           
 void finishBatch()
           
 void prepare(java.util.Map conf, TopologyContext context, BatchOutputCollector collector, java.lang.Object id)
           
 
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

KeyedSummingBatchBolt

public KeyedSummingBatchBolt()
Method Detail

prepare

public void prepare(java.util.Map conf,
                    TopologyContext context,
                    BatchOutputCollector collector,
                    java.lang.Object id)

execute

public void execute(Tuple tuple)

finishBatch

public void finishBatch()

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