pyflink.datastream.data_stream.ConnectedStreams.flat_map

ConnectedStreams.flat_map(func: CoFlatMapFunction, output_type: Optional[TypeInformation] = None) → DataStream

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