pyflink.datastream.data_stream.KeyedStream.map

KeyedStream.map(func: Union[Callable, pyflink.datastream.functions.MapFunction], output_type: Optional[pyflink.common.typeinfo.TypeInformation] = None) → pyflink.datastream.data_stream.DataStream

Applies a Map transformation on a KeyedStream. 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.