xarray_beam.DatasetToZarr

class xarray_beam.DatasetToZarr(dataset, store, zarr_chunks=None)

Write an entire xarray.Dataset to a Zarr store.

Parameters:
  • dataset (xarray.Dataset)

  • store (WritableStore)

  • zarr_chunks (Mapping[str, int] | None)

__init__(dataset, store, zarr_chunks=None)
Parameters:
  • dataset (Dataset)

  • store (str | Store | StorePath | FSMap | Path | dict[str, Buffer] | PathLike[str])

  • zarr_chunks (Mapping[str, int] | None)

Return type:

None

Methods

__init__(dataset, store[, zarr_chunks])

annotations()

default_label()

default_type_hints()

display_data()

Returns the display data associated to a pipeline component.

expand(pcoll)

from_runner_api(proto, context)

get_resource_hints()

get_type_hints()

Gets and/or initializes type hints for this object.

get_windowing(inputs)

Returns the window function to be associated with transform's output.

infer_output_type(unused_input_type)

register_urn(urn, parameter_type[, constructor])

runner_api_requires_keyed_input()

to_runner_api(context[, has_parts])

to_runner_api_parameter(unused_context)

to_runner_api_pickled(context)

type_check_inputs(pvalueish)

type_check_inputs_or_outputs(pvalueish, ...)

type_check_outputs(pvalueish)

with_input_types(input_type_hint)

Annotates the input type of a PTransform with a type-hint.

with_output_types(type_hint)

Annotates the output type of a PTransform with a type-hint.

with_resource_hints(**kwargs)

Adds resource hints to the PTransform.

Attributes

label

pipeline

side_inputs

zarr_chunks