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

    All Methods Instance Methods Abstract Methods
    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 Detail

    - #### init

          T init​(Object batchId,
                 TridentCollector collector)

    - #### aggregate

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

    - #### complete

          void complete​(T val,
                        TridentCollector collector)