Я установил Dask на OSX Mojave.По умолчанию он выполняет вычисления параллельно?Или мне нужно...

У меня есть dask dataframe со 100 разделами (объединяющими 100 json-файлов, которые составляют...

Я пытаюсь распараллелить вложенный цикл, используя дистрибутив dask, который выглядит следующим...

Я пытаюсь использовать dask.distributed для отправки очень долго работающего задания на несколько...

Я новичок в dask, и мне было очень приятно иметь модуль, который облегчает параллелизацию.Я работаю...

У меня кластер Kubernetes, настроенный с использованием Kubernetes Engine на GCP.Я также установил...

У меня есть фрейм данных со столбцами a, b, c и d.Все типы данных - целые числа. У меня есть...

import dask.distributed def f(x, y): return x, y client = dask.distributed.Client() client.map(f,...

У меня есть dask Client с его рабочими. И я хочу, чтобы мои вычисления были выполнены в два этапа:...

При настройке кластера dask с помощью Helm в файле config.yaml есть набор переменных для настройки...

client = Client('127.0.0.1:8786',direct_to_workers=True) future1 = client.submit(Counter,...

У меня огромный фрейм данных dask с npartitions = 8, я применил несколько функций для создания...

Я работаю с Dask в Kubernetes, используя Helm Chart в хранилище stable / dask.При использовании...

Я долго выполняю задания dask.delayed () (использующие подпроцесс для запуска внешних двоичных...

Я использую Dask для распределения работы по кластеру.Я создаю кластер и вызываю .submit() для...

Я нахожусь на dask 1.1.1 (последняя версия), и я запустил планировщик dask в командной строке с...

Я не могу понять, как изящно выпустить выделенный SLURMCluster.Мой код делает это: from dask_import...

Я использую Dask YARN для создания такого приложения: spec = skein.ApplicationSpec( ... ) cluster =...

У меня есть небольшой кластер, на котором я развертываю граф dask, используя: from dask.distributed...

Я пытаюсь преобразовать столбец в категорию для выполнения операции сводной таблицы. Я пробовал...

У меня есть CSV-файл с около 2 миллионов строк.Этот CSV-файл имеет столбец, который я установил в...

Я прочитал около 15 CSV-файлов: df = dd.read_csv("gs://project/*.csv", blocksize=25e6,...

Я застрял в странном месте.У меня есть куча отложенных вызовов функций, которые я хочу выполнить в...

В распределенной Dask документации они имеют следующую информацию: Например, разработчики Dask...

У меня есть dask массивы, которые представляют кадры видео и я хочу создать несколько видеофайлов.Я...