Skip to content Skip to sidebar Skip to footer

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?"