IO

IO

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

Create an Array collection from a concrete awkward.Array object.

from_dask_array(array[, behavior])

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

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

Create an Array collection from a set of Delayed objects.

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

Create an Awkward Array collection from JSON data.

from_lists(source[, behavior])

Create an Array 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, ...])

Create an Array collection from a Parquet dataset.

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

Convert Array collection to a dask.array.Array collection.

to_dask_bag(array)

Convert Array collection to a dask.bag.Bag collection.

to_dataframe(array[, optimize_graph])

Convert dask_awkward.Array collection to DataFrame.

to_delayed(array[, optimize_graph])

Convert Arrray 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, ...])

Write data to line delimited JSON.