storm.trident.operation
Interface GroupedMultiReducer<T>

All Superinterfaces:
java.io.Serializable
All Known Implementing Classes:
JoinerMultiReducer

public interface GroupedMultiReducer<T>
extends java.io.Serializable


Method Summary
 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(java.util.Map conf, TridentMultiReducerContext context)
           
 

Method Detail

prepare

void prepare(java.util.Map 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()