Uses of Interface
org.apache.storm.trident.operation.MultiReducer
Package
Description
-
Uses of MultiReducer in org.apache.storm.trident
Modifier and TypeMethodDescriptionTridentTopology.multiReduce
(List<Stream> streams, MultiReducer function, Fields outputFields) TridentTopology.multiReduce
(List<Fields> inputFields, List<Stream> streams, MultiReducer function, Fields outputFields) TridentTopology.multiReduce
(Stream s1, Stream s2, MultiReducer function, Fields outputFields) TridentTopology.multiReduce
(Fields inputFields1, Stream s1, Fields inputFields2, Stream s2, MultiReducer function, Fields outputFields) -
Uses of MultiReducer in org.apache.storm.trident.drpc
-
Uses of MultiReducer in org.apache.storm.trident.operation
-
Uses of MultiReducer in org.apache.storm.trident.operation.impl
-
Uses of MultiReducer in org.apache.storm.trident.planner.processor
ModifierConstructorDescriptionMultiReducerProcessor
(List<Fields> inputFields, MultiReducer reducer)