Decompress the data from Zarr to MS (decompressms)#

visco.decompress_ms.construct_main_ds(zarr_path: str, column: str, batch_size: int)#

Construct the full main table dataset.

Parameters:

  • (str) (column) – The path to the zarr store.

  • (str) – The column in which the compressed data is stored in in the zarr store.

Return type:

maintable dataset (xarray dataset)

visco.decompress_ms.open_dataset(zarr_path: str, column: str = 'COMPRESSED_DATA', group: Optional[str] = None, batch_size: int = 50)#

” Open the zarr store in a MSv2 format including the SVD components.

Parameters:

  • (str) (group) – The path to the zarr store.

  • (str) – The column in which the compressed data is stored in in the zarr store.

  • (str) – MS group/subtable to open. If none, the main table is opened. Default is None.

Return type:

dataset (xarray dataset)

visco.decompress_ms.write_datasets_to_ms(zarr_path: str, msname: str, column: str, batch_size: int)#

” Write all the datasets to the Measurement set.

Parameters:

  • (str) (column) – The path to the zarr store.

  • (str) – The name of the output MS.

  • (str) – The column in which the compressed data is stored in in the zarr store.

  • (int) (batch_size) – Number of baseline reconstruction tasks to process in a batch.

Return type:

None