Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

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[source]#

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.

previous

pyflink.datastream.data_stream.DataStreamSink.slot_sharing_group

next

pyflink.datastream.data_stream.KeyedStream.flat_map

Show Source

Created using Sphinx 4.5.0.