Source code for dask_expr.io.records

from dask.utils import M



[docs]def to_records(df):
    return df.map_partitions(M.to_records)