Uses of Class
org.apache.storm.streams.PairStream
Packages that use PairStream
-
Uses of PairStream in org.apache.storm.streams
Methods in org.apache.storm.streams that return PairStreamModifier and TypeMethodDescription<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 givenCombinerAggregator.<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>[] Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.PairStream.coGroupByKey(PairStream<K, V1> otherStream) Groups the values of this stream with the values having the same key from the other stream.PairStream.countByKey()Counts the values for each key of this stream.PairStream<K,V> 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 aFlatMapFunctionfunction 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 aPairFunctionon each value of this stream.<R> PairStream<K,R> Returns a new stream by applying aFunctionto 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 newPairStreamof key-value pairs from the givenIRichSpoutby extracting key and value from tuples via the suppliedPairValueMapper.<K,V> PairStream<K, V> StreamBuilder.newStream(IRichSpout spout, PairValueMapper<K, V> pairValueMapper, int parallelism) Creates a newPairStreamof key-value pairs from the givenIRichSpoutby extracting key and value from tuples via the suppliedPairValueMapperand with the given value of parallelism.PairStream<K,V> 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> 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 PairStreamModifier and TypeMethodDescriptionPairStream.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.