python - 调用 dask.distributed.Executor 和 dask.distributed.Client 有什么区别

Question

我对 dask 文档中的并发期货要点有疑问：https ://gist.github.com/mrocklin/ef9ccd29a6ec5f4de84d6192be95042a

当我们实例化一个 Executor 时，这是否意味着它也实例化了一个调度器？执行人的代表说

<Client: scheduler='tcp://127.0.0.1:60329' processes=4 cores=4>

那么调用Client()和Executor()有什么区别呢？如果不一样，文档似乎非常相似。在并发期货示例中，一些首先实例化一个客户端，然后使用客户端的 IP 地址实例化一个执行器。

Answer 1

它们完全相同。Executor 是 Client 的旧名称。

最初 Dask 使用该术语Executor来匹配concurrent.futures API。然而，这个术语对于 Spark 用户来说是令人困惑的，因为它Executor被用于他们的工人等价物。我们将该术语更改为Executor2016Client年，最终将弃用该术语。