我想知道是否有可能将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
进入发电机?
暂无答案!
目前还没有任何答案,快来回答吧!