pyflink.datastream.data_stream.ConnectedStreams.map

ConnectedStreams.map(func: pyflink.datastream.functions.CoMapFunction, output_type: Optional[pyflink.common.typeinfo.TypeInformation] = None) → pyflink.datastream.data_stream.DataStream

Applies a CoMap transformation on a ConnectedStreams and maps the output to a common type. The transformation calls a CoMapFunction.map1 for each element of the first input and CoMapFunction.map2 for each element of the second input. Each CoMapFunction call returns exactly one element.

Parameters

• func – The CoMapFunction used to jointly transform the two input DataStreams

• output_type – TypeInformation for the result type of the function.

Returns

The transformed DataStream