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