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