storm.trident.operation

Interface GroupedMultiReducer<T>

All Superinterfaces:

Serializable

All Known Implementing Classes:

JoinerMultiReducer

public interface GroupedMultiReducer<T>
extends Serializable

Method Summary

Methods

Modifier and Type	Method and 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 conf, TridentMultiReducerContext context)

Method Detail

prepare

void prepare(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()