xarray_beam.in_memory_rechunk

xarray_beam.in_memory_rechunk(inputs, target_chunks)[source]

Rechunk in-memory pairs of (Key, xarray.Dataset).

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

  • target_chunks (Mapping[str, int])

Return type:

Iterator[tuple[Key, Dataset]]