dask_awkward.from_delayed

Contents

dask_awkward.from_delayed#

dask_awkward.from_delayed(source, meta=None, behavior=None, divisions=None, prefix='from-delayed', attrs=None)[source]#

Create an Array collection from a set of Delayed objects.

Parameters:

  • source (list[dask.delayed.Delayed] | dask.delayed.Delayed) – List of Delayed objects (or a single object). Each Delayed object represents a single partition in the resulting awkward array.

  • meta (ak.Array, optional) – Metadata (typetracer array) if known, if None the first partition (first element of the list of Delayed objects) will be computed to determine the metadata.

  • behavior (dict, optional) – Custom ak.behavior for the output array.

  • divisions (tuple[int | None, ...], optional) – Partition boundaries (if known).

  • prefix (str) – Prefix for the keys in the task graph.

  • attrs (mapping, optional) – Custom attributes for the output array.

Returns:

Resulting Array collection.

Return type:

Array

Contents