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

У меня есть большой набор данных xarray, загруженный в кадр данных dask, который содержит данные...

Я использую Dask: import dask.dataframe as dd dsk = dd.read_parquet('/tmp/parquet/f1

Как вернуть несколько значений из функции, примененной к серии Dask?Я пытаюсь вернуть серию из...

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

Кажется, что все документы относятся к localhost. Каковы параметры подключения для работы Клиента...

Я пытаюсь прочитать несколько файлов CSV из Google Cloud Storage в кадры данных pandas, как описано...

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

Я новичок в даске, и мне было интересно, кто-нибудь может мне помочь.У меня большой набор текстовых...

Я в основном конвертирую некоторые csv файлы в parquet.Для этого я решил использовать dask,...

Этот вопрос предназначен для применения лямбда-функции к кадру данных dask .Это решение, не...

Я использую delayed для чтения большого количества CSV-файлов: import pandas as pd def...

Я пытаюсь выполнить остановку на фрейме данных dask wnl = WordNetLemmatizer() def...

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

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

Я пытаюсь изменить значения nan для item_price на среднее значение на основе item_id в следующем...

Я новичок в DASK. Я могу отправить 10 задач, используя client.map (имя_функции, итератор), где...

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

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

Предположим, я сгенерирую массив с формой, которая зависит от некоторых вычислений, таких как:...

У меня есть фрейм данных: import numpy as np import pandas as pd import dask.dataframe as dd a =...

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

У меня есть скрипт на python, который использует библиотеку Dask для обработки слияния очень...

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

Я пытаюсь создать большой фрейм данных (main_df), который в конечном итоге будет создан путем...