dask

2зной

1ответ

dask DataFrame.assign взрывает диаграмму dask

Так что у меня проблема с dask DataFrame.append. Я генерирую много производных функций из основных данных и добавляю их к основному фреймворку. После этого взорвался граф dask для любого набора столбц

1зной

1ответ

Какие типы сжатия поддерживают блокирование в dask?

При обработке большого отдельного файла, он может быть разбит таким образом: import dask.bag as db my_file = db.read_text('filename', blocksize=int(1e7)) Это прекрасно работает, но файлы, я работа

1зной

1ответ

dask-ec2 имя-ключа не существует

Я пытаюсь использовать dask-ec2 для установки кластера EC2 на AWS, но столкнулся с некоторыми проблемами при попытке команды «dask-ec2 up». Ошибки я получаю: ERROR: The keyname 'my_keyname_here' does

0зной

1ответ

Scikit-Learn с Dask-Распространяется с использованием вложенного параллелизма?

Например предположим, у меня есть код: vectorizer = CountVectorizer(input=u'filename', decode_error=u'replace') classifier = OneVsRestClassifier(LinearSVC()) pipeline = Pipeline([ ('vect', vectoriz

1зной

1ответ

Ошибка при экспорте DASK dataframe в CSV

Мой DASK dataframe около 120 мм строк и 4 столбца: df_final.dtypes cust_id int64 score float64 total_qty float64 update_score float64 dtype: object и я делаю эту операцию на jupyter ноутбу

1зной

1ответ

Группировка элементов dask.bag в отдельных разделах

Мне было интересно, может ли кто-нибудь помочь мне разобраться в способе Bag объекты обрабатывают разделы. Проще говоря, я пытаюсь группировать элементы, находящиеся в настоящее время в Bag, так что к

2зной

2ответ

Даска используя отсроченной для построения списка функций, но указать номер процесса использовать

У меня есть функция, чтобы сделать вычисление, здесь просто один в качестве примера, def add(a,b): return a+b И тогда я выполнить эту функцию 100 раз смущающе параллельным образом, output = [de