org.apache.storm.trident.operation.impl

Class JoinerMultiReducer

java.lang.Object

org.apache.storm.trident.operation.impl.JoinerMultiReducer

All Implemented Interfaces:

Serializable, GroupedMultiReducer<JoinState>

public class JoinerMultiReducer
extends Object
implements GroupedMultiReducer<JoinState>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JoinerMultiReducer(List<JoinType> types, int numGroupFields, List<Fields> sides)

Method Summary

Modifier and Type	Method and Description
void	cleanup()
void	complete(JoinState state, TridentTuple group, TridentCollector collector)
void	execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
JoinState	init(TridentCollector collector, TridentTuple group)
void	prepare(Map<String,Object> conf, TridentMultiReducerContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinerMultiReducer

public JoinerMultiReducer(List<JoinType> types,
                          int numGroupFields,
                          List<Fields> sides)

Method Detail

prepare

public void prepare(Map<String,Object> conf,
                    TridentMultiReducerContext context)

Specified by:

prepare in interface GroupedMultiReducer<JoinState>

init

public JoinState init(TridentCollector collector,
                      TridentTuple group)

Specified by:

init in interface GroupedMultiReducer<JoinState>

execute

public void execute(JoinState state,
                    int streamIndex,
                    TridentTuple group,
                    TridentTuple input,
                    TridentCollector collector)

Specified by:

execute in interface GroupedMultiReducer<JoinState>

complete

public void complete(JoinState state,
                     TridentTuple group,
                     TridentCollector collector)

Specified by:

complete in interface GroupedMultiReducer<JoinState>

cleanup

public void cleanup()

Specified by:

cleanup in interface GroupedMultiReducer<JoinState>