Dask数据框不支持有效的迭代或行分配。通常，这些工作流很难很好地扩展。它们在熊猫本身中也相当慢。
相反，您可以考虑使用Series.where方法。这是一个最小的示例：
In [1]: import pandas as pdIn [2]: df = pd.Dataframe({'x': [1, 2, 3], 'y': [3, 2, 1]})In [3]: import dask.dataframe as ddIn [4]: ddf = dd.from_pandas(df, npartitions=2)In [5]: ddf['z'] = ddf.x.where(ddf.x > ddf.y, ddf.y)In [6]: ddf.compute()Out[6]: x y z0 1 3 31 2 2 22 3 1 3
