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 newConnectedStreams
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 newBroadcastConnectedStream
by connecting the currentDataStream
with aBroadcastStream
. The latter can be created using thebroadcast()
method. The resulting stream can be further processed using theBroadcastConnectedStream.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