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

  - ### init

    T init()

  - ### reduce

    T reduce(T curr, TridentTuple tuple)