Class LogInfoBolt

    • Constructor Detail

      • LogInfoBolt

        public LogInfoBolt()
    • Method Detail

      • 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