storm.trident.operation
Interface CombinerAggregator<T>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

Count, Sum

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

Method Summary

T	combine(T val1, T val2)
T	init(TridentTuple tuple)
T	zero()

Method Detail

init

T init(TridentTuple tuple)

combine

T combine(T val1,
          T val2)

zero

T zero()