xarray_beam.consolidate_chunks

xarray_beam.consolidate_chunks(inputs, combine_kwargs=None)

Consolidate chunks across offsets into (Key, Dataset) pairs.

Parameters:

• inputs (Iterable[Tuple[Key, Dataset]]) –

• combine_kwargs (Optional[Mapping[str, Any]]) –

Return type:

Iterable[Tuple[Key, Dataset]]