Uses of Class
org.apache.storm.trident.operation.impl.JoinState
-
Uses of JoinState in org.apache.storm.trident.operation.impl
Modifier and TypeMethodDescriptionJoinerMultiReducer.init
(TridentCollector collector, TridentTuple group) PreservingFieldsOrderJoinerMultiReducer.init
(TridentCollector collector, TridentTuple group) Modifier and TypeMethodDescriptionvoid
JoinerMultiReducer.complete
(JoinState state, TridentTuple group, TridentCollector collector) void
PreservingFieldsOrderJoinerMultiReducer.complete
(JoinState state, TridentTuple group, TridentCollector collector) void
JoinerMultiReducer.execute
(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) void
PreservingFieldsOrderJoinerMultiReducer.execute
(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)