public class JoinerMultiReducer extends Object implements GroupedMultiReducer<JoinerMultiReducer.JoinState>
Modifier and Type | Class and Description |
---|---|
static class |
JoinerMultiReducer.JoinState |
Constructor and Description |
---|
JoinerMultiReducer(List<JoinType> types,
int numGroupFields,
List<Fields> sides) |
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) |
public void prepare(Map conf, TridentMultiReducerContext context)
prepare
in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>
public JoinerMultiReducer.JoinState init(TridentCollector collector, TridentTuple group)
init
in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>
public void execute(JoinerMultiReducer.JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
execute
in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>
public void complete(JoinerMultiReducer.JoinState state, TridentTuple group, TridentCollector collector)
complete
in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>
public void cleanup()
cleanup
in interface GroupedMultiReducer<JoinerMultiReducer.JoinState>
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.