Skip to content

Commit a628141

Browse files
committed
update plan
Signed-off-by: weimingdiit <weimingdiit@gmail.com>
1 parent 4fa0953 commit a628141

23 files changed

Lines changed: 6042 additions & 6106 deletions

File tree

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q1.txt

Lines changed: 239 additions & 243 deletions
Large diffs are not rendered by default.

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q11.txt

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
== Physical Plan ==
22
AdaptiveSparkPlan (255)
33
+- == Final Plan ==
4-
TakeOrderedAndProject (153)
5-
+- * Project (152)
6-
+- * SortMergeJoin Inner (151)
4+
NativeTakeOrdered (153)
5+
+- NativeProject (152)
6+
+- NativeSortMergeJoin Inner (151)
77
:- NativeProject (123)
88
: +- NativeSortMergeJoin Inner (122)
99
: :- NativeProject (78)
@@ -888,19 +888,19 @@ Input [2]: [customer_id#71, year_total#72]
888888
Input [2]: [customer_id#71, year_total#72]
889889
Arguments: [customer_id#71 ASC NULLS FIRST], false
890890

891-
(151) SortMergeJoin [codegen id : X]
891+
(151) NativeSortMergeJoin
892892
Left keys [1]: [customer_id#19]
893893
Right keys [1]: [customer_id#71]
894894
Join type: Inner
895895
Join condition: (CASE WHEN (year_total#56 > 0.00) THEN (year_total#72 / year_total#56) END > CASE WHEN (year_total#20 > 0.00) THEN (year_total#37 / year_total#20) END)
896896

897-
(152) Project [codegen id : X]
897+
(152) NativeProject
898898
Output [1]: [customer_preferred_cust_flag#36]
899899
Input [7]: [customer_id#19, year_total#20, customer_preferred_cust_flag#36, year_total#37, year_total#56, customer_id#71, year_total#72]
900900

901-
(153) TakeOrderedAndProject
901+
(153) NativeTakeOrdered
902902
Input [1]: [customer_preferred_cust_flag#36]
903-
Arguments: X, [customer_preferred_cust_flag#36 ASC NULLS FIRST], [customer_preferred_cust_flag#36]
903+
Arguments: X, X, [customer_preferred_cust_flag#36 ASC NULLS FIRST]
904904

905905
(154) Scan parquet
906906
Output [8]: [c_customer_sk#1, c_customer_id#2, c_first_name#3, c_last_name#4, c_preferred_cust_flag#5, c_birth_country#6, c_login#7, c_email_address#8]

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q13.txt

Lines changed: 158 additions & 156 deletions
Large diffs are not rendered by default.

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q15.txt

Lines changed: 154 additions & 158 deletions
Large diffs are not rendered by default.

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q19.txt

Lines changed: 234 additions & 220 deletions
Large diffs are not rendered by default.

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q30.txt

Lines changed: 314 additions & 318 deletions
Large diffs are not rendered by default.

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q31.txt

Lines changed: 580 additions & 584 deletions
Large diffs are not rendered by default.

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q32.txt

Lines changed: 180 additions & 184 deletions
Large diffs are not rendered by default.

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q4.txt

Lines changed: 615 additions & 619 deletions
Large diffs are not rendered by default.

dev/auron-it/src/main/resources/tpcds-plan-stability/spark-3.5/q46.txt

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
== Physical Plan ==
22
AdaptiveSparkPlan (156)
33
+- == Final Plan ==
4-
TakeOrderedAndProject (99)
5-
+- * Project (98)
6-
+- * SortMergeJoin Inner (97)
4+
NativeTakeOrdered (99)
5+
+- NativeProject (98)
6+
+- NativeSortMergeJoin Inner (97)
77
:- NativeSort (90)
88
: +- InputAdapter (89)
99
: +- AQEShuffleRead (88)
@@ -564,19 +564,19 @@ Input [2]: [#33#33, #34#34]
564564
Input [2]: [#33#33, #34#34]
565565
Arguments: [ca_address_sk#33 ASC NULLS FIRST], false
566566

567-
(97) SortMergeJoin [codegen id : X]
567+
(97) NativeSortMergeJoin
568568
Left keys [1]: [c_current_addr_sk#30]
569569
Right keys [1]: [ca_address_sk#33]
570570
Join type: Inner
571571
Join condition: NOT (ca_city#34 = bought_city#26)
572572

573-
(98) Project [codegen id : X]
573+
(98) NativeProject
574574
Output [7]: [c_last_name#32, c_first_name#31, ca_city#34, bought_city#26, ss_ticket_number#6, amt#27, profit#28]
575575
Input [9]: [ss_ticket_number#6, bought_city#26, amt#27, profit#28, c_current_addr_sk#30, c_first_name#31, c_last_name#32, #33#33, #34#34]
576576

577-
(99) TakeOrderedAndProject
577+
(99) NativeTakeOrdered
578578
Input [7]: [c_last_name#32, c_first_name#31, ca_city#34, bought_city#26, ss_ticket_number#6, amt#27, profit#28]
579-
Arguments: X, [c_last_name#32 ASC NULLS FIRST, c_first_name#31 ASC NULLS FIRST, ca_city#34 ASC NULLS FIRST, bought_city#26 ASC NULLS FIRST, ss_ticket_number#6 ASC NULLS FIRST], [c_last_name#32, c_first_name#31, ca_city#34, bought_city#26, ss_ticket_number#6, amt#27, profit#28]
579+
Arguments: X, X, [c_last_name#32 ASC NULLS FIRST, c_first_name#31 ASC NULLS FIRST, ca_city#34 ASC NULLS FIRST, bought_city#26 ASC NULLS FIRST, ss_ticket_number#6 ASC NULLS FIRST]
580580

581581
(100) Scan parquet
582582
Output [8]: [ss_sold_date_sk#1, ss_customer_sk#2, ss_hdemo_sk#3, ss_addr_sk#4, ss_store_sk#5, ss_ticket_number#6, ss_coupon_amt#7, ss_net_profit#8]

0 commit comments

Comments
 (0)