storm.trident.operation
Interface ReducerAggregator<T>

All Superinterfaces:
java.io.Serializable

public interface ReducerAggregator<T>
extends java.io.Serializable


Method Summary
 T init()
           
 T reduce(T curr, TridentTuple tuple)
           
 

Method Detail

init

T init()

reduce

T reduce(T curr,
         TridentTuple tuple)