IO

IO

from_awkward(source, npartitions[, ...])

Create a Dask collection from a concrete awkward array.

from_dask_array(array[, behavior])

Convert a Dask Array collection to a Dask Awkard Array collection.

from_delayed(source[, meta, behavior, ...])

Create a Dask Awkward Array from Dask Delayed objects.

from_json(urlpath[, schema, highlevel, ...])

Create an Awkward Array collection from JSON data.

from_lists(source[, behavior])

Create a Dask collection from a list of lists.

from_map(func, *iterables[, args, label, ...])

Create an Array collection from a custom mapping.

from_parquet(path[, storage_options, ...])

Read parquet dataset into an Array collection.

to_dask_array(array, *[, dtype, optimize_graph])

Convert awkward array collection to a Dask array collection.

to_delayed(array[, optimize_graph])

Convert the collection to a list of delayed objects.

to_parquet(data, path[, storage_options, ...])

Write data to parquet format.

to_json(array, path[, line_delimited, ...])