Package org.apache.storm.trident.operation

Interface ReducerAggregator<T>

All Superinterfaces:
Serializable
public interface ReducerAggregator<T> extends Serializable

  • Method Summary

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

  • Method Details