org.apache.storm.trident.operation

Interface ReducerAggregator<T>

All Superinterfaces:

Serializable

public interface ReducerAggregator<T>
extends Serializable

Method Summary

Modifier and Type	Method and Description
T	init()
T	reduce(T curr, TridentTuple tuple)

Method Detail

init

T init()

reduce

T reduce(T curr,
         TridentTuple tuple)