pyflink.datastream.data_stream.CachedDataStream.rebalance#

CachedDataStream.rebalance() → DataStream#

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.