pyflink.datastream.data_stream.DataStream.broadcast# DataStream.broadcast() → pyflink.datastream.data_stream.DataStream[source]# Sets the partitioning of the DataStream so that the output elements are broadcasted to every parallel instance of the next operation. Returns The DataStream with broadcast partitioning set.