dask_awkward.to_parquet

dask_awkward.to_parquet¶

dask_awkward.to_parquet(data, path, storage_options=None, write_metadata=False, compute=True, prefix=None)[source]¶

Write data to Parquet format.

Parameters

data (dask_awkward.Array) – Array to write to parquet.
path (str) – Root directory of location to write to
storage_options (dict) – Arguments to pass to fsspec for creating the filesystem (see fsspec documentation).
write_metadata (bool) – Whether to create _metadata and _common_metadata files
compute (bool) – Whether to immediately start writing or to return the dask collection which can be computed at the user’s discression.

Returns

If compute is False, a dask_awkward.Scalar representing the process will be returned, if compute is True then the return is None.

Return type

None or dask_awkward.Scalar

dask_awkward.to_delayed

dask_awkward.to_json