Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

pyflink.datastream.data_stream.KeyedStream.connect#

KeyedStream.connect(ds: DataStream) → ConnectedStreams[source]#
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

previous

pyflink.datastream.data_stream.KeyedStream.union

next

pyflink.datastream.data_stream.KeyedStream.partition_custom

Show Source

Created using Sphinx 4.5.0.