storm.trident.operation
Interface Aggregator<T>
- All Superinterfaces:
- Operation, java.io.Serializable
- All Known Implementing Classes:
- BaseAggregator, ChainedAggregatorImpl, CombinerAggregatorCombineImpl, CountAsAggregator, FirstN.FirstNAgg, FirstN.FirstNSortedAgg, GroupedAggregator, ReducerAggregatorImpl, SingleEmitAggregator
public interface Aggregator<T>
- extends Operation
init
T init(java.lang.Object batchId,
TridentCollector collector)
aggregate
void aggregate(T val,
TridentTuple tuple,
TridentCollector collector)
complete
void complete(T val,
TridentCollector collector)