storm.trident.operation.impl
Class GroupedMultiReducerExecutor

java.lang.Object
  storm.trident.operation.impl.GroupedMultiReducerExecutor

All Implemented Interfaces:

java.io.Serializable, MultiReducer<java.util.Map<TridentTuple,java.lang.Object>>

public class GroupedMultiReducerExecutor
extends java.lang.Object
implements MultiReducer<java.util.Map<TridentTuple,java.lang.Object>>

See Also:

Serialized Form

Constructor Summary

GroupedMultiReducerExecutor(GroupedMultiReducer reducer, java.util.List<Fields> groupFields, java.util.List<Fields> inputFields)

Method Summary

void	cleanup()
void	complete(java.util.Map<TridentTuple,java.lang.Object> state, TridentCollector collector)
void	execute(java.util.Map<TridentTuple,java.lang.Object> state, int streamIndex, TridentTuple full, TridentCollector collector)
java.util.Map<TridentTuple,java.lang.Object>	init(TridentCollector collector)
void	prepare(java.util.Map conf, TridentMultiReducerContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GroupedMultiReducerExecutor

public GroupedMultiReducerExecutor(GroupedMultiReducer reducer,
                                   java.util.List<Fields> groupFields,
                                   java.util.List<Fields> inputFields)

Method Detail

prepare

public void prepare(java.util.Map conf,
                    TridentMultiReducerContext context)

Specified by:

prepare in interface MultiReducer<java.util.Map<TridentTuple,java.lang.Object>>

init

public java.util.Map<TridentTuple,java.lang.Object> init(TridentCollector collector)

Specified by:

init in interface MultiReducer<java.util.Map<TridentTuple,java.lang.Object>>

execute

public void execute(java.util.Map<TridentTuple,java.lang.Object> state,
                    int streamIndex,
                    TridentTuple full,
                    TridentCollector collector)

Specified by:

execute in interface MultiReducer<java.util.Map<TridentTuple,java.lang.Object>>

complete

public void complete(java.util.Map<TridentTuple,java.lang.Object> state,
                     TridentCollector collector)

Specified by:

complete in interface MultiReducer<java.util.Map<TridentTuple,java.lang.Object>>

cleanup

public void cleanup()

Specified by:

cleanup in interface MultiReducer<java.util.Map<TridentTuple,java.lang.Object>>