pyflink.datastream.data_stream.ConnectedStreams.flat_map#
- ConnectedStreams.flat_map(func: CoFlatMapFunction, output_type: TypeInformation | None = None) DataStream[source]#
Applies a CoFlatMap transformation on a ConnectedStreams and maps the output to a common type. The transformation calls a CoFlatMapFunction.flatMap1 for each element of the first input and CoFlatMapFunction.flatMap2 for each element of the second input. Each CoFlatMapFunction call returns any number of elements including none.
- Parameters:
func – The CoFlatMapFunction used to jointly transform the two input DataStreams
output_type – TypeInformation for the result type of the function.
- Returns:
The transformed DataStream