pyflink.datastream.data_stream.DataStream.connect

DataStream.connect(ds: pyflink.datastream.data_stream.DataStream) → pyflink.datastream.data_stream.ConnectedStreams

Creates a new ‘ConnectedStreams’ by connecting ‘DataStream’ outputs of (possible) different types with each other. The DataStreams connected using this operator can be used with CoFunctions to apply joint transformations.

Parameters

ds – The DataStream with which this stream will be connected.

Returns

The ConnectedStreams.