pyflink.datastream.data_stream.KeyedStream.connect#

KeyedStream.connect(ds: pyflink.datastream.data_stream.DataStream) → pyflink.datastream.data_stream.ConnectedStreams[source]#

KeyedStream.connect(ds: pyflink.datastream.data_stream.BroadcastStream) → pyflink.datastream.data_stream.BroadcastConnectedStream

If ds is a DataStream, 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.

If ds is a BroadcastStream, creates a new BroadcastConnectedStream by connecting the current DataStream with a BroadcastStream. The latter can be created using the broadcast() method. The resulting stream can be further processed using the BroadcastConnectedStream.process() method.

Parameters: ds – The DataStream or BroadcastStream with which this stream will be connected.
Returns: The ConnectedStreams or BroadcastConnectedStream.

Changed in version 1.16.0: Support connect BroadcastStream