Class ReachTopology.CountAggregator

All Implemented Interfaces:
Serializable, IBatchBolt<Object>, IComponent
Enclosing class:
ReachTopology

public static class ReachTopology.CountAggregator extends BaseBatchBolt<Object>
See Also:
  • Constructor Details

    • CountAggregator

      public CountAggregator()
  • Method Details

    • prepare

      public void prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, 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