Uses of Class
org.apache.storm.trident.fluent.GroupedStream

Packages that use GroupedStream

Package	Description
org.apache.storm.trident
org.apache.storm.trident.fluent

Uses of GroupedStream in org.apache.storm.trident

Methods in org.apache.storm.trident that return GroupedStream

Modifier and Type	Method and Description
GroupedStream	Stream.groupBy(Fields fields) Grouping Operation.

Methods in org.apache.storm.trident with parameters of type GroupedStream

Modifier and Type	Method and Description
Stream	TridentTopology.multiReduce(Fields inputFields1, GroupedStream s1, Fields inputFields2, GroupedStream s2, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(GroupedStream s1, GroupedStream s2, GroupedMultiReducer function, Fields outputFields)

Method parameters in org.apache.storm.trident with type arguments of type GroupedStream

Modifier and Type	Method and Description
Stream	TridentTopology.multiReduce(List<Fields> inputFields, List<GroupedStream> groupedStreams, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<GroupedStream> streams, GroupedMultiReducer function, Fields outputFields)

Uses of GroupedStream in org.apache.storm.trident.fluent

Methods in org.apache.storm.trident.fluent that return GroupedStream

Modifier and Type	Method and Description
GroupedStream	GroupedStream.name(String name)

Methods in org.apache.storm.trident.fluent with parameters of type GroupedStream

Modifier and Type	Method and Description
IAggregatableStream	GroupedStream.aggPartition(GroupedStream s)