storm.trident.operation

Interface CombinerAggregator<T>

All Superinterfaces:

Serializable

All Known Implementing Classes:

Count, Sum

public interface CombinerAggregator<T>
extends Serializable

Method Summary

Methods

Modifier and Type	Method and Description
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()