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
Documentation unclear, incomplete, broken or wrong? Let us know