-
Notifications
You must be signed in to change notification settings - Fork 17
Open
Labels
bugSomething isn't workingSomething isn't working
Description
When importing from catalog like glue or unity catalog dask-deltatable uses the deltalake package. This package just had a big overhaul with the v1.0.0 release. where functions like DeltaTable.from_data_catalog is removed see their documentation here. Also The DataCatalog class is removed.
They suggest moving to create path to the catalog which works quite well with existing setup by creating a
full_url = f"s3://{database_name}/{table_name}"
dt = DeltaTable(full_url)
file_paths = dt.file_uris()
ddf = dd.read_parquet(file_paths, **kwargs)
in the _read_from_catalog function.
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working