Skip to content

Commit dc15b02

Browse files
committed
fix existing cases
1 parent 3a57d0b commit dc15b02

2 files changed

Lines changed: 5 additions & 5 deletions

File tree

datafusion/sqllogictest/test_files/order.slt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1521,7 +1521,7 @@ query TT
15211521
EXPLAIN SELECT c1, c2 FROM table_with_ordered_pk ORDER BY c1, c2;
15221522
----
15231523
logical_plan
1524-
01)Sort: table_with_ordered_pk.c1 ASC NULLS LAST, table_with_ordered_pk.c2 ASC NULLS LAST
1524+
01)Sort: table_with_ordered_pk.c1 ASC NULLS LAST
15251525
02)--TableScan: table_with_ordered_pk projection=[c1, c2]
15261526
physical_plan DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/core/tests/data/aggregate_agg_multi_order.csv]]}, projection=[c1, c2], output_ordering=[c1@0 ASC NULLS LAST], constraints=[PrimaryKey([0])], file_type=csv, has_header=true
15271527

datafusion/sqllogictest/test_files/window.slt

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2439,13 +2439,13 @@ EXPLAIN SELECT c9, rn1 FROM (SELECT c9,
24392439
LIMIT 5
24402440
----
24412441
logical_plan
2442-
01)Sort: rn1 ASC NULLS LAST, aggregate_test_100.c9 ASC NULLS LAST, fetch=5
2442+
01)Sort: rn1 ASC NULLS LAST, fetch=5
24432443
02)--Projection: aggregate_test_100.c9, row_number() ORDER BY [aggregate_test_100.c9 DESC NULLS FIRST] RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW AS rn1
24442444
03)----WindowAggr: windowExpr=[[row_number() ORDER BY [aggregate_test_100.c9 DESC NULLS FIRST] RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW]]
24452445
04)------TableScan: aggregate_test_100 projection=[c9]
24462446
physical_plan
2447-
01)SortExec: TopK(fetch=5), expr=[rn1@1 ASC NULLS LAST, c9@0 ASC NULLS LAST], preserve_partitioning=[false], sort_prefix=[rn1@1 ASC NULLS LAST]
2448-
02)--ProjectionExec: expr=[c9@0 as c9, row_number() ORDER BY [aggregate_test_100.c9 DESC NULLS FIRST] RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW@1 as rn1]
2447+
01)ProjectionExec: expr=[c9@0 as c9, row_number() ORDER BY [aggregate_test_100.c9 DESC NULLS FIRST] RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW@1 as rn1]
2448+
02)--GlobalLimitExec: skip=0, fetch=5
24492449
03)----BoundedWindowAggExec: wdw=[row_number() ORDER BY [aggregate_test_100.c9 DESC NULLS FIRST] RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW: Field { "row_number() ORDER BY [aggregate_test_100.c9 DESC NULLS FIRST] RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW": UInt64 }, frame: RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW], mode=[Sorted]
24502450
04)------SortExec: expr=[c9@0 DESC], preserve_partitioning=[false]
24512451
05)--------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/testing/data/csv/aggregate_test_100.csv]]}, projection=[c9], file_type=csv, has_header=true
@@ -2514,7 +2514,7 @@ EXPLAIN SELECT c9, rn1 FROM (SELECT c9,
25142514
LIMIT 5
25152515
----
25162516
logical_plan
2517-
01)Sort: rn1 ASC NULLS LAST, aggregate_test_100.c9 DESC NULLS FIRST, fetch=5
2517+
01)Sort: rn1 ASC NULLS LAST, fetch=5
25182518
02)--Projection: aggregate_test_100.c9, row_number() ORDER BY [aggregate_test_100.c9 DESC NULLS FIRST] RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW AS rn1
25192519
03)----WindowAggr: windowExpr=[[row_number() ORDER BY [aggregate_test_100.c9 DESC NULLS FIRST] RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW]]
25202520
04)------TableScan: aggregate_test_100 projection=[c9]

0 commit comments

Comments
 (0)