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

- Packages that use Stream
  Package | Description
  --- | ---
  org.apache.storm.sql |
  org.apache.storm.sql.planner.streams |
  org.apache.storm.streams |

- - ### Uses of Stream in org.apache.storm.sql

    Fields in org.apache.storm.sql declared as Stream
    Modifier and Type | Field | Description
    --- | --- | ---
    `protected Stream<Values>` | AbstractStreamsProcessor.`outputStream` |

    Methods in org.apache.storm.sql that return Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Stream<Values>` | AbstractStreamsProcessor.`outputStream()` | Return final output stream of SQL topology structure.

  - ### Uses of Stream in org.apache.storm.sql.planner.streams

    Methods in org.apache.storm.sql.planner.streams that return Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Stream<Values>` | StreamsPlanCreator.`pop()` |

    Methods in org.apache.storm.sql.planner.streams with parameters of type Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | StreamsPlanCreator.`addStream​(Stream<Values> stream)` |

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

    Subclasses of Stream in org.apache.storm.streams
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `PairStream<K,​V>` | Represents a stream of key-value pairs.

    Methods in org.apache.storm.streams that return Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `<A,​R> Stream<R>` | Stream.`aggregate​(CombinerAggregator<? super T,​A,​? extends R> aggregator)` | Aggregates the values in this stream using the aggregator.
    `<R> Stream<R>` | Stream.`aggregate​(R initialValue, BiFunction<? super R,​? super T,​? extends R> accumulator, BiFunction<? super R,​? super R,​? extends R> combiner)` | Aggregates the values in this stream using the given initial value, accumulator and combiner.
    `Stream<T>[]` | Stream.`branch​(Predicate<? super T>... predicates)` | Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.
    `Stream<Long>` | Stream.`count()` | Counts the number of values in this stream.
    `Stream<T>` | Stream.`filter​(Predicate<? super T> predicate)` | Returns a stream consisting of the elements of this stream that matches the given filter.
    `<R> Stream<R>` | Stream.`flatMap​(FlatMapFunction<? super T,​? extends R> function)` | Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided mapping function to each value.
    `<R> Stream<R>` | Stream.`map​(Function<? super T,​? extends R> function)` | Returns a stream consisting of the result of applying the given mapping function to the values of this stream.
    `Stream<Tuple>` | StreamBuilder.`newStream​(IRichSpout spout)` | Creates a new `Stream` of tuples from the given `IRichSpout`.
    `Stream<Tuple>` | StreamBuilder.`newStream​(IRichSpout spout, int parallelism)` | Creates a new `Stream` of tuples from the given `IRichSpout` with the given parallelism.
    `<T> Stream<T>` | StreamBuilder.`newStream​(IRichSpout spout, TupleValueMapper<T> valueMapper)` | Creates a new `Stream` of values from the given `IRichSpout` by extracting field(s) from tuples via the supplied `TupleValueMapper`.
    `<T> Stream<T>` | StreamBuilder.`newStream​(IRichSpout spout, TupleValueMapper<T> valueMapper, int parallelism)` | Creates a new `Stream` of values from the given `IRichSpout` by extracting field(s) from tuples via the supplied `TupleValueMapper` with the given parallelism.
    `protected Stream<T>` | Stream.`partitionBy​(Fields fields, int parallelism)` |
    `Stream<T>` | Stream.`peek​(Consumer<? super T> 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.
    `Stream<T>` | Stream.`reduce​(Reducer<T> reducer)` | Performs a reduction on the elements of this stream, by repeatedly applying the reducer.
    `Stream<T>` | Stream.`repartition​(int parallelism)` | Returns a new stream with the given value of parallelism.
    `Stream<T>` | Stream.`window​(Window<?,​?> window)` | Returns a new stream consisting of the elements that fall within the window as specified by the window parameter.