Uses of Class
org.apache.storm.streams.Pair

Packages that use Pair

Package	Description
org.apache.storm.sql.runtime.streams.functions
org.apache.storm.streams
org.apache.storm.streams.operations
org.apache.storm.streams.operations.mappers
org.apache.storm.streams.processors
org.apache.storm.windowing

Uses of Pair in org.apache.storm.sql.runtime.streams.functions

Methods in org.apache.storm.sql.runtime.streams.functions that return Pair

Modifier and Type	Method and Description
Pair<Object,Values>	StreamInsertMapToPairFunction.apply(Values input)

Uses of Pair in org.apache.storm.streams

Methods in org.apache.storm.streams that return Pair

Modifier and Type	Method and Description
static <T1,T2> Pair<T1,T2>	Pair.of(T1 first, T2 second) Constructs a new pair of values.

Methods in org.apache.storm.streams that return types with arguments of type Pair

Modifier and Type	Method and Description
<V1> PairStream<K,Pair<Iterable<V>,Iterable<V1>>>	PairStream.coGroupByKey(PairStream<K,V1> otherStream) Groups the values of this stream with the values having the same key from the other stream.
<V1> PairStream<K,Pair<V,V1>>	PairStream.fullOuterJoin(PairStream<K,V1> otherStream) Does a full outer join of the values of this stream with the values having the same key from the other stream.
<V1> PairStream<K,Pair<V,V1>>	PairStream.join(PairStream<K,V1> otherStream) Join the values of this stream with the values having the same key from the other stream.
<V1> PairStream<K,Pair<V,V1>>	PairStream.leftOuterJoin(PairStream<K,V1> otherStream) Does a left outer join of the values of this stream with the values having the same key from the other stream.
<V1> PairStream<K,Pair<V,V1>>	PairStream.rightOuterJoin(PairStream<K,V1> otherStream) Does a right outer join of the values of this stream with the values having the same key from the other stream.

Method parameters in org.apache.storm.streams with type arguments of type Pair

Modifier and Type	Method and Description
PairStream<K,V>	PairStream.filter(Predicate<? super Pair<K,V>> predicate) Returns a stream consisting of the elements of this stream that matches the given filter.
PairStream<K,V>	PairStream.peek(Consumer<? super Pair<K,V>> action) Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as they are consumed from the resulting stream.

Uses of Pair in org.apache.storm.streams.operations

Methods in org.apache.storm.streams.operations that return Pair

Modifier and Type	Method and Description
Pair<V1,V2>	PairValueJoiner.apply(V1 value1, V2 value2) Joins two values and produces a Pair of the values as the result.

Uses of Pair in org.apache.storm.streams.operations.mappers

Methods in org.apache.storm.streams.operations.mappers that return Pair

Modifier and Type	Method and Description
Pair<K,V>	PairValueMapper.apply(Tuple input)

Uses of Pair in org.apache.storm.streams.processors

Methods in org.apache.storm.streams.processors with parameters of type Pair

Modifier and Type	Method and Description
void	CoGroupByKeyProcessor.execute(Pair<K,?> input, String sourceStream)
void	JoinProcessor.execute(Pair<K,?> input, String sourceStream)
void	MergeAggregateByKeyProcessor.execute(Pair<K,A> input)
void	ReduceByKeyProcessor.execute(Pair<K,V> input)
void	AggregateByKeyProcessor.execute(Pair<K,V> input)
protected void	UpdateStateByKeyProcessor.execute(Pair<K,V> input)
protected void	FlatMapValuesProcessor.execute(Pair<K,V> input)
void	MapValuesProcessor.execute(Pair<K,V> input)

Uses of Pair in org.apache.storm.windowing

Methods in org.apache.storm.windowing that return Pair

Modifier and Type	Method and Description
Pair<Long,Long>	WatermarkCountEvictionPolicy.getState()

Methods in org.apache.storm.windowing with parameters of type Pair

Modifier and Type	Method and Description
void	WatermarkCountEvictionPolicy.restoreState(Pair<Long,Long> state)