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