pyflink.datastream.data_stream.BroadcastStream

class BroadcastStream(input_stream: Union[DataStream, KeyedStream], broadcast_state_descriptors: List[MapStateDescriptor])

A BroadcastStream is a stream with state.BroadcastState (s). This can be created by any stream using the DataStream.broadcast() method and implicitly creates states where the user can store elements of the created BroadcastStream. (see BroadcastConnectedStream).

Note that no further operation can be applied to these streams. The only available option is to connect them with a keyed or non-keyed stream, using the KeyedStream.connect() and the DataStream.connect() respectively. Applying these methods will result it a BroadcastConnectedStream for further processing.

New in version 1.16.0.