from_dataset re-reads every dimension coordinate on each call, and the workaround loses the cftime UDF and template registry
Maintainer antworten meist innerhalb von 1 Tag
Dieses Issue hat noch niemand übernommen.
Bewertung
- Schwierigkeit
- 3/5
- Geschätzter Aufwand
- 1-2 Tage
- Anfängerfreundlichkeit
- 45/100
Rechercherichtung
Start in XarrayContext.from_dataset, where coord_arrays is built once per call, and in read_xarray_table, which already takes coord_arrays. Also check _registered_datasets and _maybe_register_cftime_udf. Done means one Dataset can register several per-variable tables with each dimension coordinate read once, while metadata recovery and the cftime() UDF still work. The issue proposes two API shapes and the maintainers have not picked one, so confirm the direction before coding.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Beschreibung
Problem
XarrayContext.from_dataset materialises the dimension coordinates once per call:
coord_arrays = {
str(dim): input_table.coords[dim].values for dim in input_table.dims
}
Within a single call those arrays are shared across every dim group, which is what the comment above them describes. Across calls nothing is shared. Registering one table per data variable, which is what you want when each variable should be its own SQL table, re-reads every coordinate once per variable.
Measured with a counting DataArray.values property, 4 data variables on a (time, lat, lon) grid:
4 x from_dataset (one per data var): 12 coord reads
1 x from_dataset (whole dataset) : 3 coord reads
Local NumPy makes this free. On a Zarr store each read is a network round trip, so registration cost scales with n_vars * n_dims instead of n_dims.
The obvious workaround is not equivalent
read_xarray_table already accepts coord_arrays, so the natural caller-side fix is to read the coordinates once and register the tables directly:
shared = {str(d): ds.coords[d].values for d in ds.dims}
ctx = XarrayContext()
for v in ds.data_vars:
ctx.register_table(v, read_xarray_table(ds[[v]], chunks, coord_arrays=shared))
That does share the reads, but bypassing from_dataset silently drops two things it does.
-
self._registered_datasets[name] = input_tableis never populated, soXarrayDataFrameloses metadata recovery. Checked:_registered_datasetsis{}afterwards, andto_dataset()then returns empty attrs and cannot inferdims. -
_maybe_register_cftime_udfnever runs, so thecftime()UDF is missing on a 360_day dataset:
cftime() escape hatch : ERR ValueError Error during planning: Invalid function 'cftime'. Did you mean 'to_time'?
cftime() from_dataset : 4 rows
So today there is no public way to register several tables out of one Dataset without either paying n_vars * n_dims coordinate reads or giving up metadata recovery and cftime support.
Possible directions
Either shape would fix it:
- Accept
coord_arraysonfrom_dataset(the parameter already exists one layer down inread_xarray_table), so a caller registering several tables from one parent Dataset can hand in the arrays it already read. - Add a per-variable split to
from_dataset, alongside the existing dim-group split, so a single call can registerair,humand so on as separate tables from one Dataset. This keeps the coordinate sharing, the_registered_datasetstracking and the cftime UDF registration together in one place.
Parent: #126
- Vorherrschende Sprache
- Python
- Sterne
- 142
- Forks
- 19
- Ø Merge
- 1 T. 9 Std.
- Gemergte PRs (30 T.)
- 9
Entwicklungsumgebung
- Kein Dockerfile und keine Docker-Compose-Datei
- Keine Pull-Request-Vorlage
- Beitragsleitfaden lesen
Erste Schritte
- Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
- Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
- Forken Sie das Repository und arbeiten Sie in einem Branch.
- Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.
Mehr aus xqlsystems/xarray-sql
-
documentation
Schwierigkeit 1/5 1-3 Stunden Anfängerfreundlichkeit 85/100
xqlsystems/xarray-sql#268 ·
Maintainer antworten meist innerhalb von 1 Tag
-
enhancement
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 64/100
xqlsystems/xarray-sql#267 ·
Maintainer antworten meist innerhalb von 1 Tag
-
Schwierigkeit 1/5 Unter einer Stunde Anfängerfreundlichkeit 74/100
xqlsystems/xarray-sql#243 ·
Maintainer antworten meist innerhalb von 1 Tag
-
publish.yml: the TestPyPI verification step is unreachable (and installs the wrong package name)Offen
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 62/100
xqlsystems/xarray-sql#242 ·
Maintainer antworten meist innerhalb von 1 Tag
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 72/100
xqlsystems/xarray-sql#237 ·
Maintainer antworten meist innerhalb von 1 Tag
Alle Issues in xqlsystems/xarray-sql
Ähnliche Issues
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 90/100
SublimeText/AdvancedNewFile#211 ·
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 73/100
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 83/100
Imbad0202/academic-research-skills#987 ·
Maintainer antworten meist innerhalb von 1 Tag
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 62/100
-
Pull-through from gcr.io returns 500 when pulling using podman/buildahEvtl. vergeben Ein verknüpfter Pull Request ist offen oder bereits gemergt. OffenIssue Triage-Needed
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 68/100
pulp/pulp_container#2581 ·
Maintainer antworten meist innerhalb von 1 Tag