dask.dataframe.DataFrame.get_分区

dask.dataframe.DataFrame.get_分区

DataFrame.get_partition(n)

获取表示第 nth 分区的 dask DataFrame/Series。

参数
n整数

要选择的0索引分区号。

返回
Dask DataFrame 或 Series

与原始对象相同的类型。

示例

>>> import dask
>>> ddf = dask.datasets.timeseries(start="2021-01-01", end="2021-01-07", freq="1h")
>>> ddf.get_partition(0)  
Dask DataFrame Structure:
                 name     id        x        y
npartitions=1
2021-01-01     string  int64  float64  float64
2021-01-02        ...    ...      ...      ...
Dask Name: get-partition, 3 graph layers