-
Notifications
You must be signed in to change notification settings - Fork 285
Closed
Labels
enhancementNew feature or requestNew feature or request
Description
What is the problem the feature request solves?
Current plan for windows is
val df = sql("SELECT a, b, c, SUM(c) OVER (PARTITION BY a) as sum_c FROM window_test")
+- !CometWindowExec [a#19, b#20, c#21, sum_c#25L], [sum(c#21) windowspecdefinition(a#19, specifiedwindowframe(RowFrame, unboundedpreceding$(), unboundedfollowing$())) AS sum_c#25L], [a#19]
+- CometSort [a#19, b#20, c#21], [a#19 ASC NULLS FIRST]
+- CometExchange hashpartitioning(a#19, 10), ENSURE_REQUIREMENTS, CometNativeShuffle, [plan_id=87]
+- CometScan [native_iceberg_compat] parquet [a#19,b#20,c#21] Batched: true, DataFilters: [], Format: CometParquet, Location: InMemoryFileIndex(1 paths)[file:/private/var/folders/6f/_s1vnnd55zgfkx7zlwnrnv0h0000gn/T/spark-89..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<a:int,b:int,c:int>
The exclamation mark usually means discrepancy for outputAttributes. Refer to #2214
Describe the potential solution
No response
Additional context
No response
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
enhancementNew feature or requestNew feature or request