| 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.map(MapFunction function)
Returns a stream consisting of the result of applying the given mapping function to the values of this stream.
|
Stream |
Stream.map(MapFunction function,
Fields outputFields)
Returns a stream consisting of the result of applying the given mapping function to the values of this stream.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
OperationAwareMapFunction
A one-one transformation function which is aware of Operation (lifecycle of the Trident component).
|
| Constructor and Description |
|---|
MapFunctionExecutor(MapFunction function) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.