pyflink.datastream.data_stream.ConnectedStreams.map#
- ConnectedStreams.map(func: CoMapFunction, output_type: Optional[TypeInformation] = None) DataStream[source]#
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