data_base ❭ utils ❭ myrepartition

myrepartition¶

data_base.utils.myrepartition(ddf, N)¶

Repartition a dask dataframe without generating more tasks.

Parameters:¶

• ddf (dask.DataFrame) – the dataframe to be repartitioned

• N (int) – the number of partitions

Returns:¶

the repartitioned dataframe

Return type:¶

dask.DataFrame