Uses of Interface
storm.trident.operation.MultiReducer

Packages that use MultiReducer

Package	Description
storm.trident
storm.trident.drpc
storm.trident.operation
storm.trident.operation.impl
storm.trident.planner.processor

Uses of MultiReducer in storm.trident

Methods in storm.trident with parameters of type MultiReducer

Modifier and Type	Method and Description
Stream	TridentTopology.multiReduce(Fields inputFields1, Stream s1, Fields inputFields2, Stream s2, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Fields> inputFields, List<Stream> streams, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Stream> streams, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(Stream s1, Stream s2, MultiReducer function, Fields outputFields)

Uses of MultiReducer in storm.trident.drpc

Classes in storm.trident.drpc that implement MultiReducer

Modifier and Type	Class and Description
class	ReturnResultsReducer

Uses of MultiReducer in storm.trident.operation

Classes in storm.trident.operation that implement MultiReducer

Modifier and Type	Class and Description
class	BaseMultiReducer<T>

Uses of MultiReducer in storm.trident.operation.impl

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

Modifier and Type	Class and Description
class	GroupedMultiReducerExecutor
class	IdentityMultiReducer

Uses of MultiReducer in storm.trident.planner.processor

Constructors in storm.trident.planner.processor with parameters of type MultiReducer

Constructor and Description
MultiReducerProcessor(List<Fields> inputFields, MultiReducer reducer)