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

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 Details

init

T init(Object batchId,
 TridentCollector collector)

aggregate

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

complete

void complete(T val,
 TridentCollector collector)