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 voidaggregate(T val, TridentTuple tuple, TridentCollector collector)voidcomplete(T val, TridentCollector collector)Tinit(Object batchId, TridentCollector collector)
-
-
-
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)
-
-