From a98e359192ab27a6b65efa16b8959595347f27b7 Mon Sep 17 00:00:00 2001 From: Raphael Hagen Date: Wed, 9 Aug 2023 15:58:01 -0700 Subject: [PATCH] Updated code block for parquet example with ReferenceFileSystem --- docs/source/advanced.rst | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/source/advanced.rst b/docs/source/advanced.rst index 9fa2d083..b7b6f4a4 100644 --- a/docs/source/advanced.rst +++ b/docs/source/advanced.rst @@ -162,9 +162,9 @@ one go and may be faster, if you have a Dask cluster available. single_ref_sets = [hdf.SingleHdf5ToZarr(_).translate() for _ in files] out_dict = combine.MultiZarrToZarr(single_ref_sets, concat_dims=["time"]).translate() os.mkdir("combined.parq") - df.refs_to_dataframe(out_dict, "combined.parq", partition=True) + df.refs_to_dataframe(out_dict, "combined.parq") - fs = fsspec.implementations.reference.DFReferenceFileSystem( + fs = fsspec.implementations.reference.ReferenceFileSystem( "combined.parq", lazy=True) ds = xr.open_dataset( fs.get_mapper(), engine="zarr",