update slt files

Author: adriangb

datafusion/sqllogictest/test_files/create_external_table.slt

@@ -252,7 +252,7 @@ EXPLAIN SELECT id FROM t ORDER BY id ASC;
 ----
 logical_plan
 01)Sort: t.id ASC NULLS LAST
-02)--TableScan: t projection=[id]
+02)--TableScan: t projection=[id] preferred_ordering=[t.id ASC NULLS LAST]
 physical_plan DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/parquet-testing/data/alltypes_plain.parquet]]}, projection=[id], output_ordering=[id@0 ASC NULLS LAST], file_type=parquet
 
 ## Test a DESC order and verify that output_ordering is ASC from the previous OBRDER BY
@@ -261,7 +261,7 @@ EXPLAIN SELECT id FROM t ORDER BY id DESC;
 ----
 logical_plan
 01)Sort: t.id DESC NULLS FIRST
-02)--TableScan: t projection=[id]
+02)--TableScan: t projection=[id] preferred_ordering=[t.id DESC NULLS FIRST]
 physical_plan
 01)SortExec: expr=[id@0 DESC], preserve_partitioning=[false]
 02)--DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/parquet-testing/data/alltypes_plain.parquet]]}, projection=[id], output_ordering=[id@0 ASC NULLS LAST], file_type=parquet

datafusion/sqllogictest/test_files/csv_files.slt

@@ -161,7 +161,7 @@ EXPLAIN SELECT * FROM partitioned_table ORDER BY int_col;
 ----
 logical_plan
 01)Sort: partitioned_table.int_col ASC NULLS LAST
-02)--TableScan: partitioned_table projection=[int_col, string_col, bigint_col, partition_col]
+02)--TableScan: partitioned_table projection=[int_col, string_col, bigint_col, partition_col] preferred_ordering=[partitioned_table.int_col ASC NULLS LAST]
 physical_plan
 01)SortPreservingMergeExec: [int_col@0 ASC NULLS LAST]
 02)--SortExec: expr=[int_col@0 ASC NULLS LAST], preserve_partitioning=[true]

datafusion/sqllogictest/test_files/cte.slt

@@ -1040,7 +1040,7 @@ logical_plan
 04)------Projection: Int64(0) AS k, Int64(0) AS v
 05)--------EmptyRelation: rows=1
 06)------Sort: r.v ASC NULLS LAST, fetch=1
-07)--------TableScan: r projection=[k, v]
+07)--------TableScan: r projection=[k, v] preferred_ordering=[r.v ASC NULLS LAST]
 physical_plan
 01)GlobalLimitExec: skip=0, fetch=5
 02)--RecursiveQueryExec: name=r, is_distinct=false

datafusion/sqllogictest/test_files/explain.slt

@@ -76,7 +76,7 @@ explain SELECT c1 FROM aggregate_test_100_with_order order by c1 ASC limit 10
 ----
 logical_plan
 01)Sort: aggregate_test_100_with_order.c1 ASC NULLS LAST, fetch=10
-02)--TableScan: aggregate_test_100_with_order projection=[c1]
+02)--TableScan: aggregate_test_100_with_order projection=[c1] preferred_ordering=[aggregate_test_100_with_order.c1 ASC NULLS LAST]
 physical_plan DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/core/tests/data/aggregate_test_100_order_by_c1_asc.csv]]}, projection=[c1], limit=10, output_ordering=[c1@0 ASC NULLS LAST], file_type=csv, has_header=true
 
 ## explain_physical_plan_only
@@ -161,7 +161,7 @@ logical_plan
 01)Dml: op=[Insert Into] table=[sink_table]
 02)--Projection: aggregate_test_100.c1 AS c1, aggregate_test_100.c2 AS c2, aggregate_test_100.c3 AS c3, aggregate_test_100.c4 AS c4, aggregate_test_100.c5 AS c5, aggregate_test_100.c6 AS c6, aggregate_test_100.c7 AS c7, aggregate_test_100.c8 AS c8, aggregate_test_100.c9 AS c9, aggregate_test_100.c10 AS c10, aggregate_test_100.c11 AS c11, aggregate_test_100.c12 AS c12, aggregate_test_100.c13 AS c13
 03)----Sort: aggregate_test_100.c1 ASC NULLS LAST
-04)------TableScan: aggregate_test_100 projection=[c1, c2, c3, c4, c5, c6, c7, c8, c9, c10, c11, c12, c13]
+04)------TableScan: aggregate_test_100 projection=[c1, c2, c3, c4, c5, c6, c7, c8, c9, c10, c11, c12, c13] preferred_ordering=[aggregate_test_100.c1 ASC NULLS LAST]
 physical_plan
 01)DataSinkExec: sink=StreamWrite { location: "../../testing/data/csv/aggregate_test_100.csv", batch_size: 8192, encoding: Csv, header: true, .. }
 02)--SortExec: expr=[c1@0 ASC NULLS LAST], preserve_partitioning=[false]
@@ -560,6 +560,7 @@ logical_plan after eliminate_one_union SAME TEXT AS ABOVE
 logical_plan after filter_null_join_keys SAME TEXT AS ABOVE
 logical_plan after eliminate_outer_join SAME TEXT AS ABOVE
 logical_plan after push_down_limit SAME TEXT AS ABOVE
+logical_plan after push_down_sort SAME TEXT AS ABOVE
 logical_plan after push_down_filter SAME TEXT AS ABOVE
 logical_plan after single_distinct_aggregation_to_group_by SAME TEXT AS ABOVE
 logical_plan after eliminate_group_by_constant SAME TEXT AS ABOVE
@@ -582,6 +583,7 @@ logical_plan after eliminate_one_union SAME TEXT AS ABOVE
 logical_plan after filter_null_join_keys SAME TEXT AS ABOVE
 logical_plan after eliminate_outer_join SAME TEXT AS ABOVE
 logical_plan after push_down_limit SAME TEXT AS ABOVE
+logical_plan after push_down_sort SAME TEXT AS ABOVE
 logical_plan after push_down_filter SAME TEXT AS ABOVE
 logical_plan after single_distinct_aggregation_to_group_by SAME TEXT AS ABOVE
 logical_plan after eliminate_group_by_constant SAME TEXT AS ABOVE

datafusion/sqllogictest/test_files/filter_without_sort_exec.slt

@@ -35,7 +35,7 @@ ORDER BY "date", "time";
 logical_plan
 01)Sort: data.date ASC NULLS LAST, data.time ASC NULLS LAST
 02)--Filter: data.ticker = Utf8View("A")
-03)----TableScan: data projection=[date, ticker, time]
+03)----TableScan: data projection=[date, ticker, time] preferred_ordering=[data.date ASC NULLS LAST, data.time ASC NULLS LAST]
 physical_plan
 01)SortPreservingMergeExec: [date@0 ASC NULLS LAST, time@2 ASC NULLS LAST]
 02)--CoalesceBatchesExec: target_batch_size=8192
@@ -52,7 +52,7 @@ ORDER BY "time"
 logical_plan
 01)Sort: data.time ASC NULLS LAST
 02)--Filter: data.ticker = Utf8View("A") AND CAST(data.time AS Date32) = data.date
-03)----TableScan: data projection=[date, ticker, time]
+03)----TableScan: data projection=[date, ticker, time] preferred_ordering=[data.time ASC NULLS LAST]
 physical_plan
 01)SortPreservingMergeExec: [time@2 ASC NULLS LAST]
 02)--CoalesceBatchesExec: target_batch_size=8192
@@ -69,7 +69,7 @@ ORDER BY "date"
 logical_plan
 01)Sort: data.date ASC NULLS LAST
 02)--Filter: data.ticker = Utf8View("A") AND CAST(data.time AS Date32) = data.date
-03)----TableScan: data projection=[date, ticker, time]
+03)----TableScan: data projection=[date, ticker, time] preferred_ordering=[data.date ASC NULLS LAST]
 physical_plan
 01)SortPreservingMergeExec: [date@0 ASC NULLS LAST]
 02)--CoalesceBatchesExec: target_batch_size=8192
@@ -86,7 +86,7 @@ ORDER BY "ticker"
 logical_plan
 01)Sort: data.ticker ASC NULLS LAST
 02)--Filter: data.ticker = Utf8View("A") AND CAST(data.time AS Date32) = data.date
-03)----TableScan: data projection=[date, ticker, time]
+03)----TableScan: data projection=[date, ticker, time] preferred_ordering=[data.ticker ASC NULLS LAST]
 physical_plan
 01)CoalescePartitionsExec
 02)--CoalesceBatchesExec: target_batch_size=8192
@@ -103,7 +103,7 @@ ORDER BY "time", "date";
 logical_plan
 01)Sort: data.time ASC NULLS LAST, data.date ASC NULLS LAST
 02)--Filter: data.ticker = Utf8View("A") AND CAST(data.time AS Date32) = data.date
-03)----TableScan: data projection=[date, ticker, time]
+03)----TableScan: data projection=[date, ticker, time] preferred_ordering=[data.time ASC NULLS LAST, data.date ASC NULLS LAST]
 physical_plan
 01)SortPreservingMergeExec: [time@2 ASC NULLS LAST, date@0 ASC NULLS LAST]
 02)--CoalesceBatchesExec: target_batch_size=8192
@@ -121,7 +121,7 @@ ORDER BY "time"
 logical_plan
 01)Sort: data.time ASC NULLS LAST
 02)--Filter: data.ticker = Utf8View("A") AND CAST(data.time AS Date32) != data.date
-03)----TableScan: data projection=[date, ticker, time]
+03)----TableScan: data projection=[date, ticker, time] preferred_ordering=[data.time ASC NULLS LAST]
 
 # no relation between time & date
 # should also be pipeline breaking
@@ -133,7 +133,7 @@ ORDER BY "time"
 logical_plan
 01)Sort: data.time ASC NULLS LAST
 02)--Filter: data.ticker = Utf8View("A")
-03)----TableScan: data projection=[date, ticker, time]
+03)----TableScan: data projection=[date, ticker, time] preferred_ordering=[data.time ASC NULLS LAST]
 
 # query
 query TT
@@ -144,7 +144,7 @@ ORDER BY "ticker", "time";
 logical_plan
 01)Sort: data.ticker ASC NULLS LAST, data.time ASC NULLS LAST
 02)--Filter: data.date = Date32("2006-01-02")
-03)----TableScan: data projection=[date, ticker, time]
+03)----TableScan: data projection=[date, ticker, time] preferred_ordering=[data.ticker ASC NULLS LAST, data.time ASC NULLS LAST]
 physical_plan
 01)SortPreservingMergeExec: [ticker@1 ASC NULLS LAST, time@2 ASC NULLS LAST]
 02)--CoalesceBatchesExec: target_batch_size=8192

datafusion/sqllogictest/test_files/group_by.slt

@@ -2066,7 +2066,7 @@ EXPLAIN SELECT a FROM multiple_ordered_table ORDER BY b DESC;
 logical_plan
 01)Projection: multiple_ordered_table.a
 02)--Sort: multiple_ordered_table.b DESC NULLS FIRST
-03)----TableScan: multiple_ordered_table projection=[a, b]
+03)----TableScan: multiple_ordered_table projection=[a, b] preferred_ordering=[multiple_ordered_table.b DESC NULLS FIRST]
 physical_plan
 01)ProjectionExec: expr=[a@0 as a]
 02)--SortExec: expr=[b@1 DESC], preserve_partitioning=[false]
@@ -2080,7 +2080,7 @@ EXPLAIN SELECT a FROM multiple_ordered_table ORDER BY c ASC;
 logical_plan
 01)Projection: multiple_ordered_table.a
 02)--Sort: multiple_ordered_table.c ASC NULLS LAST
-03)----TableScan: multiple_ordered_table projection=[a, c]
+03)----TableScan: multiple_ordered_table projection=[a, c] preferred_ordering=[multiple_ordered_table.c ASC NULLS LAST]
 physical_plan DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/core/tests/data/window_2.csv]]}, projection=[a], output_ordering=[a@0 ASC NULLS LAST], file_type=csv, has_header=true
 
 # Final plan shouldn't have SortExec a ASC, b ASC,
@@ -2091,7 +2091,7 @@ EXPLAIN SELECT a FROM multiple_ordered_table ORDER BY a ASC, b ASC;
 logical_plan
 01)Projection: multiple_ordered_table.a
 02)--Sort: multiple_ordered_table.a ASC NULLS LAST, multiple_ordered_table.b ASC NULLS LAST
-03)----TableScan: multiple_ordered_table projection=[a, b]
+03)----TableScan: multiple_ordered_table projection=[a, b] preferred_ordering=[multiple_ordered_table.a ASC NULLS LAST, multiple_ordered_table.b ASC NULLS LAST]
 physical_plan DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/core/tests/data/window_2.csv]]}, projection=[a], output_ordering=[a@0 ASC NULLS LAST], file_type=csv, has_header=true
 
 # test_window_agg_sort
@@ -2248,7 +2248,7 @@ ORDER BY a, b, d;
 ----
 logical_plan
 01)Sort: annotated_data_infinite2.a ASC NULLS LAST, annotated_data_infinite2.b ASC NULLS LAST, annotated_data_infinite2.d ASC NULLS LAST
-02)--TableScan: annotated_data_infinite2 projection=[a0, a, b, c, d]
+02)--TableScan: annotated_data_infinite2 projection=[a0, a, b, c, d] preferred_ordering=[annotated_data_infinite2.a ASC NULLS LAST, annotated_data_infinite2.b ASC NULLS LAST, annotated_data_infinite2.d ASC NULLS LAST]
 physical_plan
 01)PartialSortExec: expr=[a@1 ASC NULLS LAST, b@2 ASC NULLS LAST, d@4 ASC NULLS LAST], common_prefix_length=[2]
 02)--StreamingTableExec: partition_sizes=1, projection=[a0, a, b, c, d], infinite_source=true, output_ordering=[a@1 ASC NULLS LAST, b@2 ASC NULLS LAST, c@3 ASC NULLS LAST]
@@ -2261,7 +2261,7 @@ LIMIT 50;
 ----
 logical_plan
 01)Sort: annotated_data_infinite2.a ASC NULLS LAST, annotated_data_infinite2.b ASC NULLS LAST, annotated_data_infinite2.d ASC NULLS LAST, fetch=50
-02)--TableScan: annotated_data_infinite2 projection=[a0, a, b, c, d]
+02)--TableScan: annotated_data_infinite2 projection=[a0, a, b, c, d] preferred_ordering=[annotated_data_infinite2.a ASC NULLS LAST, annotated_data_infinite2.b ASC NULLS LAST, annotated_data_infinite2.d ASC NULLS LAST]
 physical_plan
 01)PartialSortExec: TopK(fetch=50), expr=[a@1 ASC NULLS LAST, b@2 ASC NULLS LAST, d@4 ASC NULLS LAST], common_prefix_length=[2]
 02)--StreamingTableExec: partition_sizes=1, projection=[a0, a, b, c, d], infinite_source=true, output_ordering=[a@1 ASC NULLS LAST, b@2 ASC NULLS LAST, c@3 ASC NULLS LAST]
@@ -2273,7 +2273,7 @@ ORDER BY a, b, d;
 ----
 logical_plan
 01)Sort: multiple_ordered_table.a ASC NULLS LAST, multiple_ordered_table.b ASC NULLS LAST, multiple_ordered_table.d ASC NULLS LAST
-02)--TableScan: multiple_ordered_table projection=[a0, a, b, c, d]
+02)--TableScan: multiple_ordered_table projection=[a0, a, b, c, d] preferred_ordering=[multiple_ordered_table.a ASC NULLS LAST, multiple_ordered_table.b ASC NULLS LAST, multiple_ordered_table.d ASC NULLS LAST]
 physical_plan
 01)SortExec: expr=[a@1 ASC NULLS LAST, b@2 ASC NULLS LAST, d@4 ASC NULLS LAST], preserve_partitioning=[false]
 02)--DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/core/tests/data/window_2.csv]]}, projection=[a0, a, b, c, d], output_orderings=[[a@1 ASC NULLS LAST, b@2 ASC NULLS LAST], [c@3 ASC NULLS LAST]], file_type=csv, has_header=true
@@ -2535,7 +2535,7 @@ logical_plan
 02)--Aggregate: groupBy=[[s.country]], aggr=[[array_agg(s.amount) ORDER BY [s.amount DESC NULLS FIRST], sum(CAST(s.amount AS Float64))]]
 03)----SubqueryAlias: s
 04)------Sort: sales_global.country ASC NULLS LAST, fetch=10
-05)--------TableScan: sales_global projection=[country, amount]
+05)--------TableScan: sales_global projection=[country, amount] preferred_ordering=[sales_global.country ASC NULLS LAST]
 physical_plan
 01)ProjectionExec: expr=[country@0 as country, array_agg(s.amount) ORDER BY [s.amount DESC NULLS FIRST]@1 as amounts, sum(s.amount)@2 as sum1]
 02)--AggregateExec: mode=Single, gby=[country@0 as country], aggr=[array_agg(s.amount) ORDER BY [s.amount DESC NULLS FIRST], sum(s.amount)], ordering_mode=Sorted
@@ -2573,7 +2573,7 @@ logical_plan
 02)--Aggregate: groupBy=[[s.country, s.zip_code]], aggr=[[array_agg(s.amount) ORDER BY [s.amount DESC NULLS FIRST], sum(CAST(s.amount AS Float64))]]
 03)----SubqueryAlias: s
 04)------Sort: sales_global.country ASC NULLS LAST, fetch=10
-05)--------TableScan: sales_global projection=[zip_code, country, amount]
+05)--------TableScan: sales_global projection=[zip_code, country, amount] preferred_ordering=[sales_global.country ASC NULLS LAST]
 physical_plan
 01)ProjectionExec: expr=[country@0 as country, zip_code@1 as zip_code, array_agg(s.amount) ORDER BY [s.amount DESC NULLS FIRST]@2 as amounts, sum(s.amount)@3 as sum1]
 02)--AggregateExec: mode=Single, gby=[country@1 as country, zip_code@0 as zip_code], aggr=[array_agg(s.amount) ORDER BY [s.amount DESC NULLS FIRST], sum(s.amount)], ordering_mode=PartiallySorted([0])
@@ -2610,7 +2610,7 @@ logical_plan
 02)--Aggregate: groupBy=[[s.country]], aggr=[[array_agg(s.amount) ORDER BY [s.country DESC NULLS FIRST], sum(CAST(s.amount AS Float64))]]
 03)----SubqueryAlias: s
 04)------Sort: sales_global.country ASC NULLS LAST, fetch=10
-05)--------TableScan: sales_global projection=[country, amount]
+05)--------TableScan: sales_global projection=[country, amount] preferred_ordering=[sales_global.country ASC NULLS LAST]
 physical_plan
 01)ProjectionExec: expr=[country@0 as country, array_agg(s.amount) ORDER BY [s.country DESC NULLS FIRST]@1 as amounts, sum(s.amount)@2 as sum1]
 02)--AggregateExec: mode=Single, gby=[country@0 as country], aggr=[array_agg(s.amount) ORDER BY [s.country DESC NULLS FIRST], sum(s.amount)], ordering_mode=Sorted
@@ -2646,7 +2646,7 @@ logical_plan
 02)--Aggregate: groupBy=[[s.country]], aggr=[[array_agg(s.amount) ORDER BY [s.country DESC NULLS FIRST, s.amount DESC NULLS FIRST], sum(CAST(s.amount AS Float64))]]
 03)----SubqueryAlias: s
 04)------Sort: sales_global.country ASC NULLS LAST, fetch=10
-05)--------TableScan: sales_global projection=[country, amount]
+05)--------TableScan: sales_global projection=[country, amount] preferred_ordering=[sales_global.country ASC NULLS LAST]
 physical_plan
 01)ProjectionExec: expr=[country@0 as country, array_agg(s.amount) ORDER BY [s.country DESC NULLS FIRST, s.amount DESC NULLS FIRST]@1 as amounts, sum(s.amount)@2 as sum1]
 02)--AggregateExec: mode=Single, gby=[country@0 as country], aggr=[array_agg(s.amount) ORDER BY [s.country DESC NULLS FIRST, s.amount DESC NULLS FIRST], sum(s.amount)], ordering_mode=Sorted
@@ -3906,7 +3906,7 @@ ORDER BY c ASC;
 ----
 logical_plan
 01)Sort: multiple_ordered_table.c ASC NULLS LAST
-02)--TableScan: multiple_ordered_table projection=[c]
+02)--TableScan: multiple_ordered_table projection=[c] preferred_ordering=[multiple_ordered_table.c ASC NULLS LAST]
 physical_plan DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/core/tests/data/window_2.csv]]}, projection=[c], output_ordering=[c@0 ASC NULLS LAST], file_type=csv, has_header=true
 
 statement ok
@@ -4392,7 +4392,7 @@ EXPLAIN SELECT name, date_bin('15 minutes', ts) as time_chunks
 logical_plan
 01)Sort: unbounded_csv_with_timestamps2.name DESC NULLS FIRST, time_chunks DESC NULLS FIRST, fetch=5
 02)--Projection: unbounded_csv_with_timestamps2.name, date_bin(IntervalMonthDayNano("IntervalMonthDayNano { months: 0, days: 0, nanoseconds: 900000000000 }"), unbounded_csv_with_timestamps2.ts) AS time_chunks
-03)----TableScan: unbounded_csv_with_timestamps2 projection=[name, ts]
+03)----TableScan: unbounded_csv_with_timestamps2 projection=[name, ts] preferred_ordering=[unbounded_csv_with_timestamps2.name DESC NULLS FIRST, date_bin(IntervalMonthDayNano("IntervalMonthDayNano { months: 0, days: 0, nanoseconds: 900000000000 }"), unbounded_csv_with_timestamps2.ts) DESC NULLS FIRST]
 physical_plan
 01)SortPreservingMergeExec: [name@0 DESC, time_chunks@1 DESC], fetch=5
 02)--ProjectionExec: expr=[name@0 as name, date_bin(IntervalMonthDayNano { months: 0, days: 0, nanoseconds: 900000000000 }, ts@1) as time_chunks]

datafusion/sqllogictest/test_files/insert.slt

@@ -215,7 +215,7 @@ logical_plan
 01)Dml: op=[Insert Into] table=[table_without_values]
 02)--Projection: aggregate_test_100.c1 AS c1
 03)----Sort: aggregate_test_100.c1 ASC NULLS LAST
-04)------TableScan: aggregate_test_100 projection=[c1]
+04)------TableScan: aggregate_test_100 projection=[c1] preferred_ordering=[aggregate_test_100.c1 ASC NULLS LAST]
 physical_plan
 01)DataSinkExec: sink=MemoryTable (partitions=1)
 02)--SortExec: expr=[c1@0 ASC NULLS LAST], preserve_partitioning=[false]

datafusion/sqllogictest/test_files/insert_to_external.slt

@@ -521,7 +521,7 @@ logical_plan
 01)Dml: op=[Insert Into] table=[table_without_values]
 02)--Projection: aggregate_test_100.c1 AS c1
 03)----Sort: aggregate_test_100.c1 ASC NULLS LAST
-04)------TableScan: aggregate_test_100 projection=[c1]
+04)------TableScan: aggregate_test_100 projection=[c1] preferred_ordering=[aggregate_test_100.c1 ASC NULLS LAST]
 physical_plan
 01)DataSinkExec: sink=ParquetSink(file_groups=[])
 02)--SortExec: expr=[c1@0 ASC NULLS LAST], preserve_partitioning=[false]

datafusion/sqllogictest/test_files/joins.slt

@@ -3890,7 +3890,7 @@ logical_plan
 03)----TableScan: left_table_no_nulls projection=[a, b]
 04)--SubqueryAlias: rhs
 05)----Sort: right_table_no_nulls.b ASC NULLS LAST, fetch=10
-06)------TableScan: right_table_no_nulls projection=[a, b]
+06)------TableScan: right_table_no_nulls projection=[a, b] preferred_ordering=[right_table_no_nulls.b ASC NULLS LAST]
 physical_plan
 01)ProjectionExec: expr=[a@2 as a, b@3 as b, a@0 as a, b@1 as b]
 02)--CoalesceBatchesExec: target_batch_size=3
@@ -4008,7 +4008,7 @@ logical_plan
 03)----TableScan: left_table_no_nulls projection=[a, b]
 04)--SubqueryAlias: rhs
 05)----Sort: right_table_no_nulls.b ASC NULLS LAST, fetch=10
-06)------TableScan: right_table_no_nulls projection=[a, b]
+06)------TableScan: right_table_no_nulls projection=[a, b] preferred_ordering=[right_table_no_nulls.b ASC NULLS LAST]
 physical_plan
 01)ProjectionExec: expr=[a@2 as a, b@3 as b, a@0 as a, b@1 as b]
 02)--CoalesceBatchesExec: target_batch_size=3

datafusion/sqllogictest/test_files/limit.slt

@@ -562,7 +562,7 @@ explain SELECT * FROM data ORDER BY column1 LIMIT 3,3;
 logical_plan
 01)Limit: skip=3, fetch=3
 02)--Sort: data.column1 ASC NULLS LAST, fetch=6
-03)----TableScan: data projection=[column1, column2]
+03)----TableScan: data projection=[column1, column2] preferred_ordering=[data.column1 ASC NULLS LAST]
 physical_plan
 01)GlobalLimitExec: skip=3, fetch=3
 02)--StreamingTableExec: partition_sizes=1, projection=[column1, column2], infinite_source=true, fetch=6, output_ordering=[column1@0 ASC NULLS LAST, column2@1 ASC NULLS LAST]
@@ -848,7 +848,7 @@ logical_plan
 03)----Projection: Int64(1) AS foo, selection.part_key
 04)------SubqueryAlias: selection
 05)--------Sort: test_limit_with_partitions.part_key ASC NULLS LAST, fetch=1
-06)----------TableScan: test_limit_with_partitions projection=[part_key]
+06)----------TableScan: test_limit_with_partitions projection=[part_key] preferred_ordering=[test_limit_with_partitions.part_key ASC NULLS LAST]
 physical_plan
 01)ProjectionExec: expr=[1 as foo]
 02)--SortPreservingMergeExec: [part_key@0 ASC NULLS LAST], fetch=1