Class JoinerMultiReducer
java.lang.Object
org.apache.storm.trident.operation.impl.JoinerMultiReducer
- All Implemented Interfaces:
Serializable
,GroupedMultiReducer<JoinState>
- See Also:
-
Constructor Summary
ConstructorDescriptionJoinerMultiReducer
(List<JoinType> types, int numGroupFields, List<Fields> sides) -
Method Summary
Modifier and TypeMethodDescriptionvoid
cleanup()
void
complete
(JoinState state, TridentTuple group, TridentCollector collector) void
execute
(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) init
(TridentCollector collector, TridentTuple group) void
prepare
(Map<String, Object> conf, TridentMultiReducerContext context)
-
Constructor Details
-
JoinerMultiReducer
-
-
Method Details
-
prepare
- Specified by:
prepare
in interfaceGroupedMultiReducer<JoinState>
-
init
- Specified by:
init
in interfaceGroupedMultiReducer<JoinState>
-
execute
public void execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) - Specified by:
execute
in interfaceGroupedMultiReducer<JoinState>
-
complete
- Specified by:
complete
in interfaceGroupedMultiReducer<JoinState>
-
cleanup
public void cleanup()- Specified by:
cleanup
in interfaceGroupedMultiReducer<JoinState>
-