storm.trident.operation.impl

Class JoinerMultiReducer

java.lang.Object

storm.trident.operation.impl.JoinerMultiReducer

All Implemented Interfaces:

Serializable, GroupedMultiReducer<JoinerMultiReducer.JoinState>

public class JoinerMultiReducer
extends Object
implements GroupedMultiReducer<JoinerMultiReducer.JoinState>

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JoinerMultiReducer.JoinState

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup()
void	complete(JoinerMultiReducer.JoinState state, TridentTuple group, TridentCollector collector)
void	execute(JoinerMultiReducer.JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
JoinerMultiReducer.JoinState	init(TridentCollector collector, TridentTuple group)
void	prepare(Map 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 conf,
           TridentMultiReducerContext context)

Specified by:

prepare in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>

init

public JoinerMultiReducer.JoinState init(TridentCollector collector,
                                TridentTuple group)

Specified by:

init in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>

execute

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

Specified by:

execute in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>

complete

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

Specified by:

complete in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>

cleanup

public void cleanup()

Specified by:

cleanup in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>