dask

0зной

1ответ

Does dask.bag.read_text() сохранить порядок строк? Сохраняется ли она при чтении из нескольких файлов? bag = db.read_text('program.log') bag = db.read_text(['program.log', 'program.log.1'])

5зной

1ответ

Преобразование панды dataframe в DASK dataframe

Предположим, у меня есть панды dataframe как: df=pd.DataFrame({'a':[1,2,3],'b':[4,5,6]}) Когда я преобразовать его в DASK dataframe что должно name и divisions параметр состоит из: from dask import

0зной

1ответ

Отзывчивый ноутбук IPython с текущим индикатором хода dask/распределенный

Я запускаю кластер с dask.distributed. В настоящее время я отправляю задачи в кластер с ноутбуком Jupyter, который я использую в качестве графического интерфейса. Соответствующая ячейка ноутбука содер

1зной

1ответ

Как запустить виджет индикатора выполнения из dask.distributed в отдельном потоке?

Приводится пример here, показывающий ввод данных для обработки в отдельном потоке. Меня интересует обратное, когда данные вставляются вручную и интерактивно, а фоновый поток отправляет их в кластер дл

2зной

1ответ

Как применить сглаживающий фильтр с dask

У меня есть 2-мерный массив, я хотел бы сделать двумерную свертку с ядром, например, простую плоскую квадратную матрицу. Смотрите, например: http://nbviewer.jupyter.org/gist/zonca/f0d819048ef7318eff94

2зной

2ответ

Как читать сжатый (gz) CSV-файл inro a dask Dataframe?

Есть ли способ прочитать CSV-файл, который сжимается через gz в dask dataframe? Я пробовал его непосредственно import dask.dataframe as dd df = dd.read_csv("Data.gz") , но получаю сообщение об ошиб