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 Description GroupedStream
Stream. groupBy(Fields fields)
## Grouping Operation.Methods in org.apache.storm.trident with parameters of type GroupedStream Modifier and Type Method Description Stream
TridentTopology. multiReduce(GroupedStream s1, GroupedStream s2, GroupedMultiReducer function, Fields outputFields)
Stream
TridentTopology. multiReduce(Fields inputFields1, GroupedStream s1, Fields inputFields2, GroupedStream s2, GroupedMultiReducer function, Fields outputFields)
Method parameters in org.apache.storm.trident with type arguments of type GroupedStream Modifier and Type Method Description 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 Description GroupedStream
GroupedStream. name(String name)
Methods in org.apache.storm.trident.fluent with parameters of type GroupedStream Modifier and Type Method Description IAggregatableStream
GroupedStream. aggPartition(GroupedStream s)
-