## 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 and Description
    --- | ---
    `protected Stream<Values>` | AbstractStreamsProcessor.`outputStream`

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

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

Copyright © 2021 The Apache Software Foundation. All rights reserved.