dask Dataframe :来自分区的生成器

egmofgnx  于 2021-08-20  发布在  Java
关注(0)|答案(0)|浏览(228)

我想知道是否有可能将dask对象转换为生成器。具体而言,我可以使用Pandas Dataframe 执行以下操作:

import pandas as pd
import dask.dataframe as dd

df = pd.DataFrame(range(10), columns=['a'])
ddf = dd.from_pandas(df, npartitions=3)

def gen_pandas(df):
    for d in df.iterrows():
        yield d

g = gen_pandas(df)
next(g), next(g)

有没有一种方法可以转动每个分区 ddf 进入发电机?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题