# 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.