Class LogInfoBolt

All Implemented Interfaces:
Serializable, IBasicBolt, IComponent

public class LogInfoBolt extends BaseBasicBolt
Simple bolt that does nothing other than LOG.info() every tuple recieveed.
See Also:
  • Constructor Details

    • LogInfoBolt

      public LogInfoBolt()
  • Method Details

    • execute

      public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector)
      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 outputFieldsDeclarer)
      Description copied from interface: IComponent
      Declare the output schema for all the streams of this topology.
      Parameters:
      outputFieldsDeclarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream