Package org.apache.storm.trident.operation

# Interface MultiReducer<T>

All Superinterfaces:
  `Serializable`

All Known Implementing Classes:
  `BaseMultiReducer`, `GroupedMultiReducerExecutor`, `IdentityMultiReducer`, `ReturnResultsReducer`

public interface MultiReducer<T> extends Serializable

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `cleanup()`
  `void`
  `complete(T state, TridentCollector collector)`
  `void`
  `execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)`
  `T`
  `init(TridentCollector collector)`
  `void`
  `prepare(Map<String,Object> conf, TridentMultiReducerContext context)`

- ## Method Details

  - ### prepare

    void prepare(Map<String,Object> conf, TridentMultiReducerContext context)

  - ### init

    T init(TridentCollector collector)

  - ### execute

    void execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)

  - ### complete

    void complete(T state, TridentCollector collector)

  - ### cleanup

    void cleanup()