Uses of Class
org.apache.storm.trident.fluent.GroupedStream
-
Uses of GroupedStream in org.apache.storm.trident
Modifier and TypeMethodDescription## Grouping Operation.Modifier and TypeMethodDescriptionTridentTopology.multiReduce
(GroupedStream s1, GroupedStream s2, GroupedMultiReducer function, Fields outputFields) TridentTopology.multiReduce
(Fields inputFields1, GroupedStream s1, Fields inputFields2, GroupedStream s2, GroupedMultiReducer function, Fields outputFields) Modifier and TypeMethodDescriptionTridentTopology.multiReduce
(List<GroupedStream> streams, GroupedMultiReducer function, Fields outputFields) -
Uses of GroupedStream in org.apache.storm.trident.fluent