Package org.apache.storm.trident.operation

## Interface GroupedMultiReducer<T>

- All Superinterfaces:
    `Serializable`
  All Known Implementing Classes:
    `JoinerMultiReducer`, `PreservingFieldsOrderJoinerMultiReducer`

      public interface GroupedMultiReducer<T>
      extends Serializable

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | `cleanup()` |
    `void` | `complete​(T state, TridentTuple group, TridentCollector collector)` |
    `void` | `execute​(T state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)` |
    `T` | `init​(TridentCollector collector, TridentTuple group)` |
    `void` | `prepare​(Map<String,​Object> conf, TridentMultiReducerContext context)` |

- - ### Method Detail

    - #### prepare

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

    - #### init

          T init​(TridentCollector collector,
                 TridentTuple group)

    - #### execute

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

    - #### complete

          void complete​(T state,
                        TridentTuple group,
                        TridentCollector collector)

    - #### cleanup

          void cleanup()