pyflink.datastream.data_stream.DataStream.rebalance# DataStream.rebalance() → pyflink.datastream.data_stream.DataStream[source]# Sets the partitioning of the DataStream so that the output elements are distributed evenly to instances of the next operation in a round-robin fashion. Returns The DataStream with rebalance partition set.