Uses of Interface
org.apache.storm.streams.operations.ValueJoiner
-
Packages that use ValueJoiner Package Description org.apache.storm.streams org.apache.storm.streams.operations org.apache.storm.streams.processors -
-
Uses of ValueJoiner in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type ValueJoiner Modifier and Type Method Description <R,V1>
PairStream<K,R>PairStream. fullOuterJoin(PairStream<K,V1> otherStream, ValueJoiner<? super V,? super V1,? extends R> valueJoiner)
Does a full outer join of the values of this stream with the values having the same key from the other stream.<R,V1>
PairStream<K,R>PairStream. join(PairStream<K,V1> otherStream, ValueJoiner<? super V,? super V1,? extends R> valueJoiner)
Join the values of this stream with the values having the same key from the other stream.<R,V1>
PairStream<K,R>PairStream. leftOuterJoin(PairStream<K,V1> otherStream, ValueJoiner<? super V,? super V1,? extends R> valueJoiner)
Does a left outer join of the values of this stream with the values having the same key from the other stream.<R,V1>
PairStream<K,R>PairStream. rightOuterJoin(PairStream<K,V1> otherStream, ValueJoiner<? super V,? super V1,? extends R> valueJoiner)
Does a right outer join of the values of this stream with the values having the same key from the other stream. -
Uses of ValueJoiner in org.apache.storm.streams.operations
Classes in org.apache.storm.streams.operations that implement ValueJoiner Modifier and Type Class Description class
PairValueJoiner<V1,V2>
AValueJoiner
that joins two values to produce aPair
of the two values as the result. -
Uses of ValueJoiner in org.apache.storm.streams.processors
Constructors in org.apache.storm.streams.processors with parameters of type ValueJoiner Constructor Description JoinProcessor(String leftStream, String rightStream, ValueJoiner<V1,V2,R> valueJoiner)
JoinProcessor(String leftStream, String rightStream, ValueJoiner<V1,V2,R> valueJoiner, JoinProcessor.JoinType leftType, JoinProcessor.JoinType rightType)
-