xarray_beam.consolidate_fully

xarray_beam.consolidate_fully(inputs, *, merge_kwargs=None, combine_kwargs=None)[source]

Consolidate chunks via merge/concat into a single (Key, Dataset) pair.

Parameters:
  • inputs (Iterable[tuple[Key, Dataset]])

  • merge_kwargs (Mapping[str, Any] | None)

  • combine_kwargs (Mapping[str, Any] | None)

Return type:

tuple[Key, Dataset]