storm.trident.operation.impl
Class JoinerMultiReducer

java.lang.Object
  extended by storm.trident.operation.impl.JoinerMultiReducer
All Implemented Interfaces:
java.io.Serializable, GroupedMultiReducer<JoinerMultiReducer.JoinState>

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

See Also:
Serialized Form

Nested Class Summary
static class JoinerMultiReducer.JoinState
           
 
Constructor Summary
JoinerMultiReducer(java.util.List<JoinType> types, int numGroupFields, java.util.List<Fields> sides)
           
 
Method Summary
 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(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

JoinerMultiReducer

public JoinerMultiReducer(java.util.List<JoinType> types,
                          int numGroupFields,
                          java.util.List<Fields> sides)
Method Detail

prepare

public void prepare(java.util.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>