Uses of Interface
org.apache.storm.trident.operation.MultiReducer
-
-
Uses of MultiReducer in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type MultiReducer Modifier and Type Method Description Stream
TridentTopology. multiReduce(List<Stream> streams, MultiReducer function, Fields outputFields)
Stream
TridentTopology. multiReduce(List<Fields> inputFields, List<Stream> streams, MultiReducer function, Fields outputFields)
Stream
TridentTopology. multiReduce(Stream s1, Stream s2, MultiReducer function, Fields outputFields)
Stream
TridentTopology. multiReduce(Fields inputFields1, Stream s1, Fields inputFields2, Stream s2, MultiReducer function, Fields outputFields)
-
Uses of MultiReducer in org.apache.storm.trident.drpc
Classes in org.apache.storm.trident.drpc that implement MultiReducer Modifier and Type Class Description class
ReturnResultsReducer
-
Uses of MultiReducer in org.apache.storm.trident.operation
Classes in org.apache.storm.trident.operation that implement MultiReducer Modifier and Type Class Description class
BaseMultiReducer<T>
-
Uses of MultiReducer in org.apache.storm.trident.operation.impl
Classes in org.apache.storm.trident.operation.impl that implement MultiReducer Modifier and Type Class Description class
GroupedMultiReducerExecutor
class
IdentityMultiReducer<T>
-
Uses of MultiReducer in org.apache.storm.trident.planner.processor
Constructors in org.apache.storm.trident.planner.processor with parameters of type MultiReducer Constructor Description MultiReducerProcessor(List<Fields> inputFields, MultiReducer reducer)
-