lt_toolbox.conversions.export_zarr_to_mfparquet

lt_toolbox.conversions.export_zarr_to_mfparquet(zarr_filename: str, parquet_filedir: str, parquet_filename: str, npartitions: int = 'auto', read_options: dict | None = None, write_options: dict | None = None) → None

Export Lagrangian trajectory properties and positions stored in array format in .zarr store to tabular format in multifile .parquet store.

Parameters:

• zarr_filename (str) – Path to input .zarr store containing Lagrangian trajectories.

• parquet_filedir (str) – Path to output .parquet store containing Lagrangian trajectories.

• parquet_filename (str) – Prefix of .parquet files containing Lagrangian trajectories.

• npartitions (int, optional) – Number of partitions to split Dask DataFrame into. The default is ‘auto’ (i.e., automatically determined by the xarray to_dask_dataframe() function).

• read_options (dict) – Dictionary of optional keyword arguments to be passed to xarray open_zarr().

• write_options (dict) – Dictionary of optional keyword arguments to be passed to dask to_parquet().

Returns:

DataFrame containing Lagrangian trajectory properties and positions in tabular format.

Return type:

parquet store