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