storm.trident.operation

Interface ReducerAggregator<T>

All Superinterfaces:

Serializable

public interface ReducerAggregator<T>
extends Serializable

Method Summary

Methods

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

Method Detail

init

T init()

reduce

T reduce(T curr,
       TridentTuple tuple)