Class CountAsAggregator

java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.operation.BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State>
org.apache.storm.trident.testing.CountAsAggregator
All Implemented Interfaces:
Serializable, Aggregator<org.apache.storm.trident.testing.CountAsAggregator.State>, Operation

public class CountAsAggregator extends BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State>
See Also:
  • Constructor Details

    • CountAsAggregator

      public CountAsAggregator()
  • Method Details

    • init

      public org.apache.storm.trident.testing.CountAsAggregator.State init(Object batchId, TridentCollector collector)
    • aggregate

      public void aggregate(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector)
    • complete

      public void complete(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentCollector collector)