pyflink.dataframe.DataFrame.rebalance

DataFrame.rebalance() → pyflink.dataframe.dataframe.DataFrame

Explicitly redistribute rows across downstream parallel subtasks in round-robin fashion.

This operation is lazy, preserves columns and row contents, and does not preserve row order. In streaming mode, this operation supports insert-only input only.