Uses of Class
storm.trident.fluent.GroupedStream

Packages that use GroupedStream

Package	Description
storm.trident
storm.trident.fluent

Uses of GroupedStream in storm.trident

Methods in storm.trident that return GroupedStream

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

Methods in 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 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 storm.trident.fluent

Methods in storm.trident.fluent that return GroupedStream

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

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

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