Class TestWordCounter

All Implemented Interfaces:
Serializable, IBasicBolt, IComponent
Direct Known Subclasses:

public class TestWordCounter extends BaseBasicBolt
See Also:
  • Field Details

    • LOG

      public static org.slf4j.Logger LOG
  • Constructor Details

    • TestWordCounter

      public TestWordCounter()
  • Method Details

    • prepare

      public void prepare(Map<String,Object> topoConf, TopologyContext context)
      Specified by:
      prepare in interface IBasicBolt
      prepare in class BaseBasicBolt
    • getTupleValue

      protected String getTupleValue(Tuple t, int idx)
    • 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.

    • cleanup

      public void cleanup()
      Specified by:
      cleanup in interface IBasicBolt
      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.
      declarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream