storm.trident.operation.impl
Class JoinerMultiReducer
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JoinerMultiReducer
public JoinerMultiReducer(java.util.List<JoinType> types,
int numGroupFields,
java.util.List<Fields> sides)
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>