Uses of Interface
org.apache.storm.trident.operation.GroupedMultiReducer

Packages that use GroupedMultiReducer

Package	Description
org.apache.storm.trident
org.apache.storm.trident.operation.impl

Uses of GroupedMultiReducer in org.apache.storm.trident

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

Modifier and Type	Method	Description
Stream	TridentTopology.multiReduce(List<GroupedStream> streams, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Fields> inputFields, List<GroupedStream> groupedStreams, GroupedMultiReducer function, Fields outputFields)
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)

Uses of GroupedMultiReducer in org.apache.storm.trident.operation.impl

Classes in org.apache.storm.trident.operation.impl that implement GroupedMultiReducer

Modifier and Type	Class	Description
class	JoinerMultiReducer
class	PreservingFieldsOrderJoinerMultiReducer

Constructors in org.apache.storm.trident.operation.impl with parameters of type GroupedMultiReducer

Constructor	Description
GroupedMultiReducerExecutor(GroupedMultiReducer reducer, List<Fields> groupFields, List<Fields> inputFields)