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

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 Details

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