Uses of Interface
org.apache.storm.streams.operations.ValueJoiner
Package
Description
-
Uses of ValueJoiner in org.apache.storm.streams
Modifier and TypeMethodDescription<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
Modifier and TypeClassDescriptionclass
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
ModifierConstructorDescriptionJoinProcessor
(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)