IO

IO#

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

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

from_dask_array(array[, behavior, attrs])

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(source, *[, line_delimited, ...])

Create an Array collection from JSON data.

from_lists(source[, behavior, attrs])

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, *[, columns, max_gap, ...])

Create an Array collection from a Parquet dataset.

from_text(source[, blocksize, delimiter, ...])

Create an Array collection from text data and a delimiter.

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(array, destination[, list_to32, ...])

Write data to Parquet format.

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

Store Array collection in JSON text.