Skip to content

Commit

Permalink
Updated code block for parquet example with ReferenceFileSystem
Browse files Browse the repository at this point in the history
  • Loading branch information
norlandrhagen committed Aug 9, 2023
1 parent 72c5d50 commit a98e359
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions docs/source/advanced.rst
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down

0 comments on commit a98e359

Please sign in to comment.