桌上平方根系列

Question

我有以下代码试图计算 dask 系列的平方根

my_dask_df['a_column'] = numpy.sqrt(my_dask_df['a_column'])

我得到的是以下异常：

ValueError: Not all divisions are known, can't align partitions. Please use `set_index` to set the index.

如何计算 dask 系列的平方根？

Answer 1

使用 ** 运算符或 da.sqrt 函数

df.x ** 0.5
# or 
import dask.array as da
da.sqrt(df.x)