Source code for dask_expr.io.records
from dask.utils import M
[docs]def to_records(df):
"""Create Dask Array from a Dask Dataframe
Warning: This creates a dask.array without precise shape information.
Operations that depend on shape information, like slicing or reshaping,
will not work.
Examples
--------
>>> df.to_records() # doctest: +SKIP
See Also
--------
dask.dataframe.DataFrame.values
dask.dataframe.from_dask_array
"""
return df.map_partitions(M.to_records)