pyflink.datastream.data_stream.KeyedStream.connect

KeyedStream.connect(ds: DataStream) → ConnectedStreams

KeyedStream.connect(ds: BroadcastStream) → 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