Uses of Class
org.apache.storm.trident.operation.impl.JoinState
Packages that use JoinState
-
Uses of JoinState in org.apache.storm.trident.operation.impl
Methods in org.apache.storm.trident.operation.impl that return JoinStateModifier and TypeMethodDescriptionJoinerMultiReducer.init
(TridentCollector collector, TridentTuple group) PreservingFieldsOrderJoinerMultiReducer.init
(TridentCollector collector, TridentTuple group) Methods in org.apache.storm.trident.operation.impl with parameters of type JoinStateModifier 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)