Заменить раздел dask - PullRequest
0 голосов
/ 29 июня 2018

Могу ли я заменить раздел dask dataframe другим разделом dask dataframe, который я создал отдельно, с таким же количеством строк и такой же структурой? Если да, то как?

Возможно ли это с другим числом строк?

1 Ответ

0 голосов
/ 29 июня 2018

Вы можете добавить разделы в начало или конец кадра данных Dask, используя функцию dd.concat.

Вы можете вставить новый раздел в любое место в кадре данных, переключившись на объекты с задержкой, вставив объект с задержкой в ​​список, а затем переключившись обратно на dask dataframe

list_of_delayed = dask_df.to_delayed()
new_partition = dask.delayed(pd.read_csv)(filename)
list_of_delayed[i] = new_partition
new_dask_df = dd.from_delayed(list_of_delayed, meta=dask_df._meta)

Может иметь разное количество строк, но должно иметь одинаковые столбцы и dtypes

...