public interface MapFunction extends Serializable
A one-one transformation function.
Modifier and Type | Method and Description |
---|---|
Values |
execute(TridentTuple input)
Invoked by the framework for each trident tuple in a stream.
|
Values execute(TridentTuple input)
Invoked by the framework for each trident tuple in a stream.
input
- the input trident tupleCopyright © 2022 The Apache Software Foundation. All rights reserved.