Uses of Interface
storm.trident.operation.GroupedMultiReducer

Packages that use GroupedMultiReducer

Package	Description
storm.trident
storm.trident.operation.impl

Uses of GroupedMultiReducer in storm.trident

Methods in storm.trident with parameters of type GroupedMultiReducer

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)
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 GroupedMultiReducer in storm.trident.operation.impl

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

Modifier and Type	Class and Description
class	JoinerMultiReducer

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

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