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