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

- Packages that use Stream
  Package | Description
  --- | ---
  org.apache.storm.trident |
  org.apache.storm.trident.fluent |
  org.apache.storm.trident.operation |
  org.apache.storm.trident.operation.builtin |

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

    Methods in org.apache.storm.trident that return Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `protected Stream` | TridentTopology.`addNode​(Node n)` |
    `Stream` | Stream.`addSharedMemory​(SharedMemory request)` |
    `protected Stream` | TridentTopology.`addSourcedNode​(List<Stream> sources, Node newNode)` |
    `protected Stream` | TridentTopology.`addSourcedNode​(Stream source, Node newNode)` |
    `Stream` | Stream.`aggregate​(Aggregator agg, Fields functionFields)` |
    `Stream` | Stream.`aggregate​(CombinerAggregator agg, Fields functionFields)` |
    `Stream` | Stream.`aggregate​(ReducerAggregator agg, Fields functionFields)` |
    `Stream` | Stream.`aggregate​(Fields inputFields, Aggregator agg, Fields functionFields)` |
    `Stream` | Stream.`aggregate​(Fields inputFields, CombinerAggregator agg, Fields functionFields)` |
    `Stream` | Stream.`aggregate​(Fields inputFields, ReducerAggregator agg, Fields functionFields)` |
    `Stream` | Stream.`applyAssembly​(Assembly assembly)` | Applies an `Assembly` to this `Stream`.
    `Stream` | Stream.`batchGlobal()` | ## Repartitioning Operation.
    `Stream` | Stream.`broadcast()` | ## Repartitioning Operation.
    `Stream` | Stream.`each​(Function function, Fields functionFields)` |
    `Stream` | Stream.`each​(Fields inputFields, Filter filter)` |
    `Stream` | Stream.`each​(Fields inputFields, Function function, Fields functionFields)` |
    `Stream` | Stream.`filter​(Filter filter)` | Returns a stream consisting of the elements of this stream that match the given filter.
    `Stream` | Stream.`filter​(Fields inputFields, Filter filter)` | Returns a stream consisting of the elements of this stream that match the given filter.
    `Stream` | Stream.`flatMap​(FlatMapFunction 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.
    `Stream` | Stream.`flatMap​(FlatMapFunction function, Fields outputFields)` | 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.
    `Stream` | Stream.`global()` | ## Repartitioning Operation.
    `Stream` | Stream.`identityPartition()` | ## Repartitioning Operation.
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinType type)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinType type, JoinOutFieldsMode mode)` |
    `Stream` | Stream.`localOrShuffle()` | ## Repartitioning Operation.
    `Stream` | Stream.`map​(MapFunction function)` | Returns a stream consisting of the result of applying the given mapping function to the values of this stream.
    `Stream` | Stream.`map​(MapFunction function, Fields outputFields)` | Returns a stream consisting of the result of applying the given mapping function to the values of this stream.
    `Stream` | Stream.`max​(Comparator<TridentTuple> comparator)` | This aggregator operation computes the maximum of tuples in a stream by using the given `comparator` with `TridentTuple`s.
    `Stream` | Stream.`maxBy​(String inputFieldName)` | This aggregator operation computes the maximum of tuples by the given `inputFieldName` and it is assumed that its value is an instance of `Comparable`.
    `<T> Stream` | Stream.`maxBy​(String inputFieldName, Comparator<T> comparator)` | This aggregator operation computes the maximum of tuples by the given `inputFieldName` in a stream by using the given `comparator`.
    `Stream` | TridentTopology.`merge​(List<Stream> streams)` |
    `Stream` | TridentTopology.`merge​(Stream... streams)` |
    `Stream` | TridentTopology.`merge​(Fields outputFields, List<Stream> streams)` |
    `Stream` | TridentTopology.`merge​(Fields outputFields, Stream... streams)` |
    `Stream` | Stream.`min​(Comparator<TridentTuple> comparator)` | This aggregator operation computes the minimum of tuples in a stream by using the given `comparator` with `TridentTuple`s.
    `Stream` | Stream.`minBy​(String inputFieldName)` | This aggregator operation computes the minimum of tuples by the given `inputFieldName` and it is assumed that its value is an instance of `Comparable`.
    `<T> Stream` | Stream.`minBy​(String inputFieldName, Comparator<T> comparator)` | This aggregator operation computes the minimum of tuples by the given `inputFieldName` in a stream by using the given `comparator`.
    `Stream` | TridentTopology.`multiReduce​(List<GroupedStream> streams, GroupedMultiReducer function, Fields outputFields)` |
    `Stream` | TridentTopology.`multiReduce​(List<Stream> streams, MultiReducer function, Fields outputFields)` |
    `Stream` | TridentTopology.`multiReduce​(List<Fields> inputFields, List<GroupedStream> groupedStreams, GroupedMultiReducer function, Fields outputFields)` |
    `Stream` | TridentTopology.`multiReduce​(List<Fields> inputFields, List<Stream> streams, MultiReducer function, Fields outputFields)` |
    `Stream` | TridentTopology.`multiReduce​(GroupedStream s1, GroupedStream s2, GroupedMultiReducer function, Fields outputFields)` |
    `Stream` | TridentTopology.`multiReduce​(Stream s1, Stream s2, MultiReducer function, Fields outputFields)` |
    `Stream` | TridentTopology.`multiReduce​(Fields inputFields1, GroupedStream s1, Fields inputFields2, GroupedStream s2, GroupedMultiReducer function, Fields outputFields)` |
    `Stream` | TridentTopology.`multiReduce​(Fields inputFields1, Stream s1, Fields inputFields2, Stream s2, MultiReducer function, Fields outputFields)` |
    `Stream` | Stream.`name​(String name)` | Applies a label to the stream.
    `Stream` | TridentTopology.`newDRPCStream​(String function)` |
    `Stream` | TridentTopology.`newDRPCStream​(String function, ILocalDRPC server)` |
    `Stream` | TridentTopology.`newStream​(String txId, IRichSpout spout)` |
    `Stream` | TridentTopology.`newStream​(String txId, IBatchSpout spout)` |
    `Stream` | TridentTopology.`newStream​(String txId, IOpaquePartitionedTridentSpout spout)` |
    `Stream` | TridentTopology.`newStream​(String txId, IPartitionedTridentSpout spout)` |
    `Stream` | TridentTopology.`newStream​(String txId, ITridentDataSource dataSource)` |
    `Stream` | TridentTopology.`newStream​(String txId, ITridentSpout spout)` |
    `Stream` | TridentState.`newValuesStream()` |
    `Stream` | Stream.`parallelismHint​(int hint)` | Applies a parallelism hint to a stream.
    `Stream` | Stream.`partition​(Grouping grouping)` | ## Repartitioning Operation.
    `Stream` | Stream.`partition​(CustomStreamGrouping partitioner)` | ## Repartitioning Operation.
    `Stream` | Stream.`partitionAggregate​(Aggregator agg, Fields functionFields)` |
    `Stream` | Stream.`partitionAggregate​(CombinerAggregator agg, Fields functionFields)` |
    `Stream` | Stream.`partitionAggregate​(ReducerAggregator agg, Fields functionFields)` |
    `Stream` | Stream.`partitionAggregate​(Fields inputFields, Aggregator agg, Fields functionFields)` |
    `Stream` | Stream.`partitionAggregate​(Fields inputFields, CombinerAggregator agg, Fields functionFields)` |
    `Stream` | Stream.`partitionAggregate​(Fields inputFields, ReducerAggregator agg, Fields functionFields)` |
    `Stream` | Stream.`partitionBy​(Fields fields)` | ## Repartitioning Operation.
    `Stream` | Stream.`peek​(Consumer action)` | Returns a stream consisting of the trident tuples of this stream, additionally performing the provided action on each trident tuple as they are consumed from the resulting stream.
    `Stream` | Stream.`project​(Fields keepFields)` | Filters out fields from a stream, resulting in a Stream containing only the fields specified by `keepFields`.
    `Stream` | Stream.`setCPULoad​(Number load)` | Sets the CPU Load resource for the current operation.
    `Stream` | Stream.`setMemoryLoad​(Number onHeap)` | Sets the Memory Load resources for the current operation.
    `Stream` | Stream.`setMemoryLoad​(Number onHeap, Number offHeap)` | Sets the Memory Load resources for the current operation.
    `Stream` | Stream.`shuffle()` | ## Repartitioning Operation.
    `Stream` | Stream.`slidingWindow​(int windowCount, int slideCount, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields)` | Returns a stream of tuples which are aggregated results of a sliding window with every `windowCount` of tuples and slides the window after `slideCount`.
    `Stream` | Stream.`slidingWindow​(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingInterval, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields)` | Returns a stream of tuples which are aggregated results of a window which slides at duration of `slidingInterval` and completes a window at `windowDuration`.
    `Stream` | Stream.`stateQuery​(TridentState state, QueryFunction function, Fields functionFields)` |
    `Stream` | Stream.`stateQuery​(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)` |
    `Stream` | Stream.`toStream()` |
    `Stream` | Stream.`tumblingWindow​(int windowCount, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields)` | Returns a stream of tuples which are aggregated results of a tumbling window with every `windowCount` of tuples.
    `Stream` | Stream.`tumblingWindow​(BaseWindowedBolt.Duration windowDuration, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields)` | Returns a stream of tuples which are aggregated results of a window that tumbles at duration of `windowDuration`.
    `Stream` | Stream.`window​(WindowConfig windowConfig, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields)` | Returns stream of aggregated results based on the given window configuration.
    `Stream` | Stream.`window​(WindowConfig windowConfig, Fields inputFields, Aggregator aggregator, Fields functionFields)` | Returns a stream of aggregated results based on the given window configuration which uses inmemory windowing tuple store.

    Methods in org.apache.storm.trident with parameters of type Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `protected Stream` | TridentTopology.`addSourcedNode​(Stream source, Node newNode)` |
    `protected TridentState` | TridentTopology.`addSourcedStateNode​(Stream source, Node newNode)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinType type)` |
    `Stream` | TridentTopology.`join​(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinType type, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`merge​(Stream... streams)` |
    `Stream` | TridentTopology.`merge​(Fields outputFields, Stream... streams)` |
    `Stream` | TridentTopology.`multiReduce​(Stream s1, Stream s2, MultiReducer function, Fields outputFields)` |
    `Stream` | TridentTopology.`multiReduce​(Fields inputFields1, Stream s1, Fields inputFields2, Stream s2, MultiReducer function, Fields outputFields)` |

    Method parameters in org.apache.storm.trident with type arguments of type Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `protected Stream` | TridentTopology.`addSourcedNode​(List<Stream> sources, Node newNode)` |
    `protected TridentState` | TridentTopology.`addSourcedStateNode​(List<Stream> sources, Node newNode)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type)` |
    `Stream` | TridentTopology.`join​(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type, JoinOutFieldsMode mode)` |
    `Stream` | TridentTopology.`merge​(List<Stream> streams)` |
    `Stream` | TridentTopology.`merge​(Fields outputFields, List<Stream> streams)` |
    `Stream` | TridentTopology.`multiReduce​(List<Stream> streams, MultiReducer function, Fields outputFields)` |
    `protected void` | TridentTopology.`registerSourcedNode​(List<Stream> sources, Node newNode)` |

  - ### Uses of Stream in org.apache.storm.trident.fluent

    Methods in org.apache.storm.trident.fluent that return Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Stream` | GroupedStream.`aggregate​(Aggregator agg, Fields functionFields)` |
    `Stream` | GroupedStream.`aggregate​(CombinerAggregator agg, Fields functionFields)` |
    `Stream` | GroupedStream.`aggregate​(ReducerAggregator agg, Fields functionFields)` |
    `Stream` | GroupedStream.`aggregate​(Fields inputFields, Aggregator agg, Fields functionFields)` |
    `Stream` | GroupedStream.`aggregate​(Fields inputFields, CombinerAggregator agg, Fields functionFields)` |
    `Stream` | GroupedStream.`aggregate​(Fields inputFields, ReducerAggregator agg, Fields functionFields)` |
    `Stream` | ChainedAggregatorDeclarer.`chainEnd()` |
    `Stream` | IChainedAggregatorDeclarer.`chainEnd()` |
    `Stream` | ChainedAggregatorDeclarer.AggregationPartition.`partition​(Stream input)` |
    `Stream` | GroupedStream.`stateQuery​(TridentState state, QueryFunction function, Fields functionFields)` |
    `Stream` | GroupedStream.`stateQuery​(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)` |
    `Stream` | GroupedStream.`toStream()` |
    `Stream` | IAggregatableStream.`toStream()` |

    Methods in org.apache.storm.trident.fluent with parameters of type Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Stream` | ChainedAggregatorDeclarer.AggregationPartition.`partition​(Stream input)` |

    Constructors in org.apache.storm.trident.fluent with parameters of type Stream
    Constructor | Description
    --- | ---
    `GroupedStream​(Stream stream, Fields groupFields)` |

  - ### Uses of Stream in org.apache.storm.trident.operation

    Methods in org.apache.storm.trident.operation that return Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Stream` | Assembly.`apply​(Stream input)` | Applies the `Assembly` to a given `Stream`.

    Methods in org.apache.storm.trident.operation with parameters of type Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Stream` | Assembly.`apply​(Stream input)` | Applies the `Assembly` to a given `Stream`.

  - ### Uses of Stream in org.apache.storm.trident.operation.builtin

    Methods in org.apache.storm.trident.operation.builtin that return Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Stream` | FirstN.`apply​(Stream input)` |

    Methods in org.apache.storm.trident.operation.builtin with parameters of type Stream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Stream` | FirstN.`apply​(Stream input)` |