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
- 
Method SummaryModifier and TypeMethodDescriptionvoidaggregate(T val, TridentTuple tuple, TridentCollector collector) voidcomplete(T val, TridentCollector collector) init(Object batchId, TridentCollector collector) 
- 
Method Details- 
init
- 
aggregate
- 
complete
 
-