Interface MapFunction
-
- All Superinterfaces:
Serializable
- All Known Subinterfaces:
OperationAwareMapFunction
public interface MapFunction extends Serializable
A one-one transformation function.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Values
execute(TridentTuple input)
Invoked by the framework for each trident tuple in a stream.
-
-
-
Method Detail
-
execute
Values execute(TridentTuple input)
Invoked by the framework for each trident tuple in a stream.- Parameters:
input
- the input trident tuple- Returns:
- the transformed values
-
-