storm.trident.operation
Interface MultiReducer<T>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

BaseMultiReducer, GroupedMultiReducerExecutor, IdentityMultiReducer, ReturnResultsReducer

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

Method Summary

void	cleanup()
void	complete(T state, TridentCollector collector)
void	execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)
T	init(TridentCollector collector)
void	prepare(java.util.Map conf, TridentMultiReducerContext context)

Method Detail

prepare

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