| Package | Description |
|---|---|
| org.apache.storm.trident | |
| org.apache.storm.trident.operation | |
| org.apache.storm.trident.operation.impl |
| Modifier and Type | Method and Description |
|---|---|
Stream |
Stream.flatMap(FlatMapFunction function)
Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided mapping function to each value.
|
Stream |
Stream.flatMap(FlatMapFunction function,
Fields outputFields)
Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided mapping function to each value.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
OperationAwareFlatMapFunction
A one to many transformation function which is aware of Operation (lifecycle of the Trident component).
|
| Constructor and Description |
|---|
FlatMapFunctionExecutor(FlatMapFunction function) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.