WindowEvaluator already provides the pure-Python window UDF base class #1577 (item 6) asks for

Offen

#1,670 erstellt am 07.8.2026 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen

Dieses Issue hat noch niemand übernommen.

Bewertung

Schwierigkeit: 5/5
Geschätzter Aufwand: Über eine Woche
Anfängerfreundlichkeit: 25/100

Issue-Typ: Feature
Klarheit: Muss geklärt werden
Aktivitätsstatus: Ruhig
Tech-Stack: python
Bereich: data-engineering

Rechercherichtung

Lesen Sie datafusion.user_defined.WindowEvaluator und crates/core/src/udwf.rs::RustPartitionEvaluator und überprüfen Sie anschließend die reinen Python-Unterklassen in python/tests/test_udwf.py. Bestimmen Sie, ob ein ABC weiterhin erforderlich ist, und definieren Sie, falls ja, einen Vertrag für die Abstraktheit, der die dokumentierte Flag-Matrix abdeckt; abgeschlossen ist die Aufgabe, wenn die angeforderte Richtung geklärt und im Issue oder Implementierungsplan festgehalten ist.

Vom Indexierungsmodell aus dem Issue-Text verfasst.

Beschreibung

Split out from #1577 (item 6), which asks for a WindowUDF ABC equivalent to Accumulator.

Checked this against current main: datafusion.user_defined.WindowEvaluator already provides the capability. crates/core/src/udwf.rs::RustPartitionEvaluator dispatches memoize / get_range / evaluate / evaluate_all / evaluate_all_with_rank / supports_bounded_execution / uses_window_frame / include_rank via call_method, and python/tests/test_udwf.py has several pure-Python subclasses driven through udwf().

It's deliberately not metaclass=ABCMeta like Accumulator, though: which evaluate* method must be implemented depends on the uses_window_frame / supports_bounded_execution / include_rank flag matrix documented on the class, so no single method can be marked @abstractmethod the way Accumulator's can.

Opening this to confirm: is the literal "ABC" form still wanted on top of what exists (and if so, what should the abstractness contract look like given the flag matrix), or should #1577 drop this item?

Vorherrschende Sprache: Python
Sterne: 605
Forks: 176
Ø Merge: 1 T. 23 Std.
Gemergte PRs (30 T.): 8

Beitragsleitfaden

Für dieses Repository ist kein Beitragsleitfaden indexiert

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 apache/datafusion-python

Allow "str" for function arguments that accept "col" expressions Offen

enhancement

Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 70/100

apache/datafusion-python#1757 · Erstellt am 22.9.2026
Rewrite the "Encode metadata, not a handle to a live object" section Offen

documentation

Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 72/100

apache/datafusion-python#1726 · Erstellt am 11.9.2026
Missing docstring examples in the `unparser` module Offen

Schwierigkeit 2/5 Ein halber Tag Anfängerfreundlichkeit 88/100

apache/datafusion-python#1691 · Erstellt am 16.8.2026
Build fails against DataFusion 54.1.0 due to new `schema` field on `RecursiveQuery` Offen

bug

Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 78/100

apache/datafusion-python#1644 · Erstellt am 24.7.2026
Allow extension libraries to contribute object stores over FFI Offen

enhancement

Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 30/100

apache/datafusion-python#1737 · Erstellt am 15.9.2026

Alle Issues in apache/datafusion-python