Package org.apache.storm.trident.operation

# Interface Aggregator<T>

All Superinterfaces:
  `Operation`, `Serializable`

All Known Implementing Classes:
  `BaseAggregator`, `ChainedAggregatorImpl`, `CombinerAggregatorCombineImpl`, `ComparisonAggregator`, `CountAsAggregator`, `FirstN.FirstNAgg`, `FirstN.FirstNSortedAgg`, `GroupedAggregator`, `Max`, `MaxWithComparator`, `Min`, `MinWithComparator`, `ReducerAggregatorImpl`, `SingleEmitAggregator`

public interface Aggregator<T> extends Operation

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `aggregate(T val, TridentTuple tuple, TridentCollector collector)`
  `void`
  `complete(T val, TridentCollector collector)`
  `T`
  `init(Object batchId, TridentCollector collector)`

  ### Methods inherited from interface org.apache.storm.trident.operation.Operation

  `cleanup, prepare`

- ## Method Details

  - ### init

    T init(Object batchId, TridentCollector collector)

  - ### aggregate

    void aggregate(T val, TridentTuple tuple, TridentCollector collector)

  - ### complete

    void complete(T val, TridentCollector collector)