| 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 © 2021 The Apache Software Foundation. All rights reserved.