pyflink.datastream.data_stream.DataStream.map

DataStream.map(func: Callable | MapFunction, output_type: TypeInformation | None = None) → DataStream

Applies a Map transformation on a DataStream. The transformation calls a MapFunction for each element of the DataStream. Each MapFunction call returns exactly one element.

Note that If user does not specify the output data type, the output data will be serialized as pickle primitive byte array.

Parameters:

• func – The MapFunction that is called for each element of the DataStream.

• output_type – The type information of the MapFunction output data.

Returns:

The transformed DataStream.