dask.bag.Item.compute

dask.bag.Item.compute

Item.compute(**kwargs)

计算这个 dask 集合

这将一个懒惰的 Dask 集合转换为其内存中的等价物。例如,一个 Dask 数组转换为一个 NumPy 数组,一个 Dask 数据框转换为一个 Pandas 数据框。在调用此操作之前,整个数据集必须适合内存。

参数
调度器字符串,可选

使用哪种调度器,如“线程”、“同步”或“进程”。如果没有提供,默认首先检查全局设置,然后回退到集合的默认设置。

优化图bool, 可选

如果为 True [默认],图表在计算前会被优化。否则,图表将按原样运行。这对于调试很有用。

kwargs

传递给调度器函数的额外关键字参数。

参见

dask.compute