Skip to content

Commit f463bcd

Browse files
authored
chore: Enable plan stability tests for native_iceberg_compat (#2519)
1 parent d92ea64 commit f463bcd

File tree

811 files changed

+135088
-71762
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

811 files changed

+135088
-71762
lines changed

spark/src/test/resources/tpcds-plan-stability/approved-plans-v1_4-spark3_5/q1.native_iceberg_compat/explain.txt

Lines changed: 137 additions & 97 deletions
Large diffs are not rendered by default.
Lines changed: 30 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
WholeStageCodegen (1)
2-
ColumnarToRow
2+
CometColumnarToRow
33
InputAdapter
44
CometTakeOrderedAndProject [c_customer_id]
55
CometProject [c_customer_id]
@@ -9,34 +9,44 @@ WholeStageCodegen (1)
99
CometProject [ctr_customer_sk,ctr_store_sk]
1010
CometBroadcastHashJoin [ctr_customer_sk,ctr_store_sk,ctr_total_return,(avg(ctr_total_return) * 1.2),ctr_store_sk]
1111
CometFilter [ctr_customer_sk,ctr_store_sk,ctr_total_return]
12-
CometHashAggregate [ctr_customer_sk,ctr_store_sk,ctr_total_return,sr_customer_sk,sr_store_sk,sum,sum(UnscaledValue(sr_return_amt))]
12+
CometHashAggregate [sum] [ctr_customer_sk,ctr_store_sk,ctr_total_return,sr_customer_sk,sr_store_sk,sum(UnscaledValue(sr_return_amt))]
1313
CometExchange [sr_customer_sk,sr_store_sk] #1
14-
CometHashAggregate [sr_customer_sk,sr_store_sk,sum,sr_return_amt]
14+
CometHashAggregate [sr_return_amt] [sr_customer_sk,sr_store_sk,sum]
1515
CometProject [sr_customer_sk,sr_store_sk,sr_return_amt]
1616
CometBroadcastHashJoin [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk,d_date_sk]
1717
CometFilter [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
18-
CometScan parquet spark_catalog.default.store_returns [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
19-
CometBroadcastExchange [d_date_sk] #2
18+
CometScan [native_iceberg_compat] parquet spark_catalog.default.store_returns [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
19+
SubqueryBroadcast [d_date_sk] #1
20+
BroadcastExchange #2
21+
WholeStageCodegen (1)
22+
CometColumnarToRow
23+
InputAdapter
24+
CometProject [d_date_sk]
25+
CometFilter [d_date_sk,d_year]
26+
CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim [d_date_sk,d_year]
27+
CometBroadcastExchange [d_date_sk] #3
2028
CometProject [d_date_sk]
2129
CometFilter [d_date_sk,d_year]
22-
CometScan parquet spark_catalog.default.date_dim [d_date_sk,d_year]
23-
CometBroadcastExchange [(avg(ctr_total_return) * 1.2),ctr_store_sk] #3
30+
CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim [d_date_sk,d_year]
31+
CometBroadcastExchange [(avg(ctr_total_return) * 1.2),ctr_store_sk] #4
2432
CometFilter [(avg(ctr_total_return) * 1.2),ctr_store_sk]
25-
CometHashAggregate [(avg(ctr_total_return) * 1.2),ctr_store_sk,sum,count,avg(ctr_total_return)]
26-
CometExchange [ctr_store_sk] #4
27-
CometHashAggregate [ctr_store_sk,sum,count,ctr_total_return]
28-
CometHashAggregate [ctr_store_sk,ctr_total_return,sr_customer_sk,sr_store_sk,sum,sum(UnscaledValue(sr_return_amt))]
29-
CometExchange [sr_customer_sk,sr_store_sk] #5
30-
CometHashAggregate [sr_customer_sk,sr_store_sk,sum,sr_return_amt]
33+
CometHashAggregate [sum,count] [(avg(ctr_total_return) * 1.2),ctr_store_sk,avg(ctr_total_return)]
34+
CometExchange [ctr_store_sk] #5
35+
CometHashAggregate [ctr_total_return] [ctr_store_sk,sum,count]
36+
CometHashAggregate [sr_customer_sk,sum] [ctr_store_sk,ctr_total_return,sr_store_sk,sum(UnscaledValue(sr_return_amt))]
37+
CometExchange [sr_customer_sk,sr_store_sk] #6
38+
CometHashAggregate [sr_return_amt] [sr_customer_sk,sr_store_sk,sum]
3139
CometProject [sr_customer_sk,sr_store_sk,sr_return_amt]
3240
CometBroadcastHashJoin [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk,d_date_sk]
3341
CometFilter [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
34-
CometScan parquet spark_catalog.default.store_returns [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
35-
ReusedExchange [d_date_sk] #2
36-
CometBroadcastExchange [s_store_sk] #6
42+
CometScan [native_iceberg_compat] parquet spark_catalog.default.store_returns [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
43+
ReusedSubquery [d_date_sk] #1
44+
ReusedExchange [d_date_sk] #3
45+
CometBroadcastExchange [s_store_sk] #7
3746
CometProject [s_store_sk]
3847
CometFilter [s_store_sk,s_state]
39-
CometScan parquet spark_catalog.default.store [s_store_sk,s_state]
40-
CometBroadcastExchange [c_customer_sk,c_customer_id] #7
41-
CometFilter [c_customer_sk,c_customer_id]
42-
CometScan parquet spark_catalog.default.customer [c_customer_sk,c_customer_id]
48+
CometScan [native_iceberg_compat] parquet spark_catalog.default.store [s_store_sk,s_state]
49+
CometBroadcastExchange [c_customer_sk,c_customer_id] #8
50+
CometProject [c_customer_id] [c_customer_sk,c_customer_id]
51+
CometFilter [c_customer_sk,c_customer_id]
52+
CometScan [native_iceberg_compat] parquet spark_catalog.default.customer [c_customer_sk,c_customer_id]

0 commit comments

Comments
 (0)