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.

Returns:

The DataStream with rebalance partition set.