backtype.storm.testing
Class TestWordCounter

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

public class TestWordCounter
extends BaseBasicBolt

See Also:
Serialized Form

Field Summary
static Logger LOG
           
 
Constructor Summary
TestWordCounter()
           
 
Method Summary
 void cleanup()
           
 void declareOutputFields(OutputFieldsDeclarer declarer)
          Declare the output schema for all the streams of this topology.
 void execute(Tuple input, BasicOutputCollector collector)
           
 void prepare(java.util.Map stormConf, TopologyContext context)
           
 
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
 

Field Detail

LOG

public static Logger LOG
Constructor Detail

TestWordCounter

public TestWordCounter()
Method Detail

prepare

public void prepare(java.util.Map stormConf,
                    TopologyContext context)
Specified by:
prepare in interface IBasicBolt
Overrides:
prepare in class BaseBasicBolt

execute

public void execute(Tuple input,
                    BasicOutputCollector collector)

cleanup

public void cleanup()
Specified by:
cleanup in interface IBasicBolt
Overrides:
cleanup 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