Package | Description |
---|---|
org.apache.storm.trident | |
org.apache.storm.trident.operation.impl |
Modifier and Type | Method and Description |
---|---|
Stream |
TridentTopology.multiReduce(Fields inputFields1,
GroupedStream s1,
Fields inputFields2,
GroupedStream s2,
GroupedMultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(GroupedStream s1,
GroupedStream s2,
GroupedMultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(List<Fields> inputFields,
List<GroupedStream> groupedStreams,
GroupedMultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(List<GroupedStream> streams,
GroupedMultiReducer function,
Fields outputFields) |
Modifier and Type | Class and Description |
---|---|
class |
JoinerMultiReducer |
class |
PreservingFieldsOrderJoinerMultiReducer |
Constructor and Description |
---|
GroupedMultiReducerExecutor(GroupedMultiReducer reducer,
List<Fields> groupFields,
List<Fields> inputFields) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.