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 TridentTuples.
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 TridentTuples.
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. offHeap becomes default.
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

Modifier	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)