Package org.apache.storm.trident.operation

Interface CombinerAggregator<T>

All Superinterfaces:
Serializable
All Known Implementing Classes:
Count, Sum, TridentReach.One
public interface CombinerAggregator<T> extends Serializable

  • Method Summary

    Modifier and Type
    Method
    Description
    T
    combine(T val1, T val2)
     
    T
    init(TridentTuple tuple)
     
    T
    zero()
     

  • Method Details

    • init

      T init(TridentTuple tuple)

    • combine

      T combine(T val1, T val2)

    • zero

      T zero()