Class PreservingFieldsOrderJoinerMultiReducer
java.lang.Object
org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer
- All Implemented Interfaces:
Serializable,GroupedMultiReducer<JoinState>
public class PreservingFieldsOrderJoinerMultiReducer
extends Object
implements GroupedMultiReducer<JoinState>
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidcleanup()voidcomplete(JoinState state, TridentTuple group, TridentCollector collector) voidexecute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) init(TridentCollector collector, TridentTuple group) voidprepare(Map<String, Object> conf, TridentMultiReducerContext context)
-
Constructor Details
-
PreservingFieldsOrderJoinerMultiReducer
-
-
Method Details
-
prepare
- Specified by:
preparein interfaceGroupedMultiReducer<JoinState>
-
init
- Specified by:
initin interfaceGroupedMultiReducer<JoinState>
-
execute
public void execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) - Specified by:
executein interfaceGroupedMultiReducer<JoinState>
-
complete
- Specified by:
completein interfaceGroupedMultiReducer<JoinState>
-
cleanup
public void cleanup()- Specified by:
cleanupin interfaceGroupedMultiReducer<JoinState>
-