Uses of Class
storm.trident.Stream

Packages that use Stream

Package	Description
storm.trident
storm.trident.fluent
storm.trident.operation
storm.trident.operation.builtin

Uses of Stream in storm.trident

Methods in storm.trident that return Stream

Modifier and Type	Method and Description
protected Stream	TridentTopology.addNode(Node n)
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(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.aggregate(ReducerAggregator agg, Fields functionFields)
Stream	Stream.applyAssembly(Assembly assembly)
Stream	Stream.batchGlobal()
Stream	Stream.broadcast()
Stream	Stream.each(Fields inputFields, Filter filter)
Stream	Stream.each(Fields inputFields, Function function, Fields functionFields)
Stream	Stream.each(Function function, Fields functionFields)
Stream	Stream.global()
Stream	Stream.identityPartition()
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed)
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, JoinType type)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed)
Stream	Stream.localOrShuffle()
Stream	TridentTopology.merge(Fields outputFields, List<Stream> streams)
Stream	TridentTopology.merge(Fields outputFields, Stream... streams)
Stream	TridentTopology.merge(List<Stream> streams)
Stream	TridentTopology.merge(Stream... streams)
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	TridentTopology.multiReduce(GroupedStream s1, GroupedStream s2, GroupedMultiReducer 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(List<GroupedStream> streams, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Stream> streams, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(Stream s1, Stream s2, MultiReducer function, Fields outputFields)
Stream	Stream.name(String name)
Stream	TridentTopology.newDRPCStream(String function)
Stream	TridentTopology.newDRPCStream(String function, ILocalDRPC server)
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, IRichSpout spout)
Stream	TridentTopology.newStream(String txId, ITridentSpout spout)
Stream	TridentState.newValuesStream()
Stream	Stream.parallelismHint(int hint)
Stream	Stream.partition(CustomStreamGrouping partitioner)
Stream	Stream.partition(Grouping grouping)
Stream	Stream.partitionAggregate(Aggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(CombinerAggregator 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.partitionAggregate(ReducerAggregator agg, Fields functionFields)
Stream	Stream.partitionBy(Fields fields)
Stream	Stream.project(Fields keepFields)
Stream	Stream.shuffle()
Stream	Stream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
Stream	Stream.stateQuery(TridentState state, QueryFunction function, Fields functionFields)
Stream	Stream.toStream()

Methods in storm.trident with parameters of type Stream

Modifier and Type	Method and 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, JoinType type)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed)
Stream	TridentTopology.merge(Fields outputFields, Stream... streams)
Stream	TridentTopology.merge(Stream... streams)
Stream	TridentTopology.multiReduce(Fields inputFields1, Stream s1, Fields inputFields2, Stream s2, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(Stream s1, Stream s2, MultiReducer function, Fields outputFields)

Method parameters in storm.trident with type arguments of type Stream

Modifier and Type	Method and 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, JoinType type)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed)
Stream	TridentTopology.merge(Fields outputFields, List<Stream> streams)
Stream	TridentTopology.merge(List<Stream> streams)
Stream	TridentTopology.multiReduce(List<Fields> inputFields, List<Stream> streams, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Stream> streams, MultiReducer function, Fields outputFields)
protected void	TridentTopology.registerSourcedNode(List<Stream> sources, Node newNode)

Uses of Stream in storm.trident.fluent

Methods in storm.trident.fluent that return Stream

Modifier and Type	Method and Description
Stream	GroupedStream.aggregate(Aggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(CombinerAggregator 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	GroupedStream.aggregate(ReducerAggregator agg, Fields functionFields)
Stream	ChainedAggregatorDeclarer.chainEnd()
Stream	IChainedAggregatorDeclarer.chainEnd()
Stream	ChainedAggregatorDeclarer.AggregationPartition.partition(Stream input)
Stream	GroupedStream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
Stream	GroupedStream.stateQuery(TridentState state, QueryFunction function, Fields functionFields)
Stream	IAggregatableStream.toStream()
Stream	GroupedStream.toStream()

Methods in storm.trident.fluent with parameters of type Stream

Modifier and Type	Method and Description
Stream	ChainedAggregatorDeclarer.AggregationPartition.partition(Stream input)

Constructors in storm.trident.fluent with parameters of type Stream

Constructor and Description
GroupedStream(Stream stream, Fields groupFields)

Uses of Stream in storm.trident.operation

Methods in storm.trident.operation that return Stream

Modifier and Type	Method and Description
Stream	Assembly.apply(Stream input)

Methods in storm.trident.operation with parameters of type Stream

Modifier and Type	Method and Description
Stream	Assembly.apply(Stream input)

Uses of Stream in storm.trident.operation.builtin

Methods in storm.trident.operation.builtin that return Stream

Modifier and Type	Method and Description
Stream	FirstN.apply(Stream input)

Methods in storm.trident.operation.builtin with parameters of type Stream

Modifier and Type	Method and Description
Stream	FirstN.apply(Stream input)