| 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)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ReturnResultsReducer  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BaseMultiReducer<T>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
GroupedMultiReducerExecutor  | 
class  | 
IdentityMultiReducer<T>  | 
| Constructor and Description | 
|---|
MultiReducerProcessor(List<Fields> inputFields,
                     MultiReducer reducer)  | 
Copyright © 2020 The Apache Software Foundation. All rights reserved.