| Package | Description |
|---|---|
| org.apache.storm.trident | |
| org.apache.storm.trident.fluent |
| Modifier and Type | Method and Description |
|---|---|
GroupedStream |
Stream.groupBy(Fields fields)
Grouping Operation.
|
| 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) |
| Modifier and Type | Method and Description |
|---|---|
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 | Method and Description |
|---|---|
GroupedStream |
GroupedStream.name(String name) |
| Modifier and Type | Method and Description |
|---|---|
IAggregatableStream |
GroupedStream.aggPartition(GroupedStream s) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.