storm.trident.operation

Interface Aggregator<T>

All Superinterfaces:

Operation, Serializable

All Known Implementing Classes:

BaseAggregator, ChainedAggregatorImpl, CombinerAggregatorCombineImpl, CountAsAggregator, FirstN.FirstNAgg, FirstN.FirstNSortedAgg, GroupedAggregator, ReducerAggregatorImpl, SingleEmitAggregator

public interface Aggregator<T>
extends Operation

Method Summary

Methods

Modifier and Type	Method and 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 storm.trident.operation.Operation

cleanup, prepare

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)