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>	A ValueJoiner that joins two values to produce a Pair 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

Modifier	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)