How Do I Convert A List Of Pandas Futures To A Dask Dataframe?
I have a list of Dask futures that point to Pandas dataframes: from dask.dataframe import Client client = Client() import pandas futures = client.map(pd.read_csv, filenames) How
Solution 1:
You probably want dask.dataframe.from_delayed
import dask.dataframe as dddf = dd.from_delayed(futures)
See the docstring for additional options.
Post a Comment for "How Do I Convert A List Of Pandas Futures To A Dask Dataframe?"