## Uses of Class
org.apache.storm.streams.PairStream

- Packages that use PairStream
  Package | Description
  --- | ---
  org.apache.storm.streams |

- - ### Uses of PairStream in org.apache.storm.streams

    Methods in org.apache.storm.streams that return PairStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `<A,​R> PairStream<K,​R>` | PairStream.`aggregateByKey​(CombinerAggregator<? super V,​A,​? extends R> aggregator)` | Aggregates the values for each key of this stream using the given `CombinerAggregator`.
    `<R> PairStream<K,​R>` | PairStream.`aggregateByKey​(R initialValue, BiFunction<? super R,​? super V,​? extends R> accumulator, BiFunction<? super R,​? super R,​? extends R> combiner)` | Aggregates the values for each key of this stream using the given initial value, accumulator and combiner.
    `PairStream<K,​V>[]` | PairStream.`branch​(Predicate<? super Pair<K,​V>>... predicates)` | Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.
    `<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.
    `PairStream<K,​Long>` | PairStream.`countByKey()` | Counts the values for each key of this stream.
    `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.
    `<K,​V> PairStream<K,​V>` | Stream.`flatMapToPair​(PairFlatMapFunction<? super T,​? extends K,​? extends V> function)` | Returns a stream consisting of the results of replacing each value of this stream with the key-value pairs produced by applying the provided mapping function to each value.
    `<R> PairStream<K,​R>` | PairStream.`flatMapValues​(FlatMapFunction<? super V,​? extends R> function)` | Return a new stream by applying a `FlatMapFunction` function to the value of each key-value pairs in this 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.
    `<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.
    `PairStream<K,​Iterable<V>>` | PairStream.`groupByKey()` | Returns a new stream where the values are grouped by the keys.
    `PairStream<K,​Iterable<V>>` | PairStream.`groupByKeyAndWindow​(Window<?,​?> window)` | Returns a new stream where the values are grouped by keys and the given window.
    `<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.
    `<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.
    `<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.
    `<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.
    `<K,​V> PairStream<K,​V>` | Stream.`mapToPair​(PairFunction<? super T,​? extends K,​? extends V> function)` | Returns a stream of key-value pairs by applying a `PairFunction` on each value of this stream.
    `<R> PairStream<K,​R>` | PairStream.`mapValues​(Function<? super V,​? extends R> function)` | Returns a new stream by applying a `Function` to the value of each key-value pairs in this stream.
    `<K,​V> PairStream<K,​V>` | StreamBuilder.`newStream​(IRichSpout spout, PairValueMapper<K,​V> pairValueMapper)` | Creates a new `PairStream` of key-value pairs from the given `IRichSpout` by extracting key and value from tuples via the supplied `PairValueMapper`.
    `<K,​V> PairStream<K,​V>` | StreamBuilder.`newStream​(IRichSpout spout, PairValueMapper<K,​V> pairValueMapper, int parallelism)` | Creates a new `PairStream` of key-value pairs from the given `IRichSpout` by extracting key and value from tuples via the supplied `PairValueMapper` and with the given value of parallelism.
    `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.
    `PairStream<K,​V>` | PairStream.`reduceByKey​(Reducer<V> reducer)` | Performs a reduction on the values for each key of this stream by repeatedly applying the reducer.
    `PairStream<K,​V>` | PairStream.`reduceByKeyAndWindow​(Reducer<V> reducer, Window<?,​?> window)` | Returns a new stream where the values that arrive within a window having the same key will be reduced by repeatedly applying the reducer.
    `PairStream<K,​V>` | PairStream.`repartition​(int parallelism)` | Returns a new stream with the given value of parallelism.
    `<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.
    `<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.
    `<V> PairStream<T,​V>` | Stream.`stateQuery​(StreamState<T,​V> streamState)` | Queries the given stream state with the values in this stream as the keys.
    `PairStream<K,​V>` | StreamState.`toPairStream()` |
    `PairStream<K,​V>` | PairStream.`window​(Window<?,​?> window)` | Returns a new stream consisting of the elements that fall within the window as specified by the window parameter.

    Methods in org.apache.storm.streams with parameters of type PairStream
    Modifier and Type | Method | 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.
    `<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.
    `<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.
    `<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.
    `<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.
    `<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.
    `<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.
    `<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.