1

对象是否dask.delayed由集群上的 dask 分发?

另外,它的任务图的执行是否也分布在集群上?

4

1 回答 1

2

简短的回答是肯定的。

用户通过将本地 Python 会话连接到调度程序并提交工作进行交互,或者通过单独调用简单接口 client.submit(function, *args, **kwargs) 或使用父 dask 的大型数据集合和并行算法图书馆。dask 库中的集合(如 dask.array 和 dask.dataframe)提供了对复杂算法和熟悉的 API(如 NumPy 和 Pandas)的轻松访问,而简单的 client.submit 接口为用户提供了自定义控制,当他们想要突破罐头“大数据”抽象并提交完全自定义的工作负载。

Dask 延迟对象包含在“父 dask 库的并行算法”中。

有关更多信息,请参阅文档。 http://distributed.dask.org/en/latest/

于 2018-11-19T11:54:51.920 回答