Skip to content

Commit 7544d83

Browse files
andygroveandygrove
authored
chore: Add extended explain plans to stability suite (#2669)
1 parent 977a189 commit 7544d83

File tree

811 files changed

+84056
-43
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

+84056
-43
lines changed

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

Lines changed: 53 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,53 @@
1+
CometColumnarToRow
2+
+- CometTakeOrderedAndProject
3+
+- CometProject
4+
+- CometBroadcastHashJoin
5+
:- CometProject
6+
: +- CometBroadcastHashJoin
7+
: :- CometProject
8+
: : +- CometBroadcastHashJoin
9+
: : :- CometFilter
10+
: : : +- CometHashAggregate
11+
: : : +- CometExchange
12+
: : : +- CometHashAggregate
13+
: : : +- CometProject
14+
: : : +- CometBroadcastHashJoin
15+
: : : :- CometFilter
16+
: : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.store_returns
17+
: : : : +- SubqueryBroadcast
18+
: : : : +- BroadcastExchange
19+
: : : : +- CometColumnarToRow
20+
: : : : +- CometProject
21+
: : : : +- CometFilter
22+
: : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
23+
: : : +- CometBroadcastExchange
24+
: : : +- CometProject
25+
: : : +- CometFilter
26+
: : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
27+
: : +- CometBroadcastExchange
28+
: : +- CometFilter
29+
: : +- CometHashAggregate
30+
: : +- CometExchange
31+
: : +- CometHashAggregate
32+
: : +- CometHashAggregate
33+
: : +- CometExchange
34+
: : +- CometHashAggregate
35+
: : +- CometProject
36+
: : +- CometBroadcastHashJoin
37+
: : :- CometFilter
38+
: : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.store_returns
39+
: : : +- ReusedSubquery
40+
: : +- CometBroadcastExchange
41+
: : +- CometProject
42+
: : +- CometFilter
43+
: : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
44+
: +- CometBroadcastExchange
45+
: +- CometProject
46+
: +- CometFilter
47+
: +- CometScan [native_iceberg_compat] parquet spark_catalog.default.store
48+
+- CometBroadcastExchange
49+
+- CometProject
50+
+- CometFilter
51+
+- CometScan [native_iceberg_compat] parquet spark_catalog.default.customer
52+
53+
Comet accelerated 46 out of 49 eligible operators (93%). Final plan contains 2 transitions between Spark and Comet.

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

Lines changed: 53 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,53 @@
1+
CometColumnarToRow
2+
+- CometTakeOrderedAndProject
3+
+- CometProject
4+
+- CometBroadcastHashJoin
5+
:- CometProject
6+
: +- CometBroadcastHashJoin
7+
: :- CometProject
8+
: : +- CometBroadcastHashJoin
9+
: : :- CometFilter
10+
: : : +- CometHashAggregate
11+
: : : +- CometExchange
12+
: : : +- CometHashAggregate
13+
: : : +- CometProject
14+
: : : +- CometBroadcastHashJoin
15+
: : : :- CometFilter
16+
: : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.store_returns
17+
: : : : +- SubqueryBroadcast
18+
: : : : +- BroadcastExchange
19+
: : : : +- CometColumnarToRow
20+
: : : : +- CometProject
21+
: : : : +- CometFilter
22+
: : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
23+
: : : +- CometBroadcastExchange
24+
: : : +- CometProject
25+
: : : +- CometFilter
26+
: : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
27+
: : +- CometBroadcastExchange
28+
: : +- CometFilter
29+
: : +- CometHashAggregate
30+
: : +- CometExchange
31+
: : +- CometHashAggregate
32+
: : +- CometHashAggregate
33+
: : +- CometExchange
34+
: : +- CometHashAggregate
35+
: : +- CometProject
36+
: : +- CometBroadcastHashJoin
37+
: : :- CometFilter
38+
: : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.store_returns
39+
: : : +- ReusedSubquery
40+
: : +- CometBroadcastExchange
41+
: : +- CometProject
42+
: : +- CometFilter
43+
: : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
44+
: +- CometBroadcastExchange
45+
: +- CometProject
46+
: +- CometFilter
47+
: +- CometScan [native_iceberg_compat] parquet spark_catalog.default.store
48+
+- CometBroadcastExchange
49+
+- CometProject
50+
+- CometFilter
51+
+- CometScan [native_iceberg_compat] parquet spark_catalog.default.customer
52+
53+
Comet accelerated 46 out of 49 eligible operators (93%). Final plan contains 2 transitions between Spark and Comet.

‎spark/src/test/resources/tpcds-plan-stability/approved-plans-v1_4-spark3_5/q10.native_iceberg_compat/extended.txt‎

Lines changed: 63 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,63 @@
1+
TakeOrderedAndProject [COMET: ]
2+
+- HashAggregate
3+
+- CometColumnarToRow
4+
+- CometColumnarExchange
5+
+- HashAggregate
6+
+- Project
7+
+- BroadcastHashJoin
8+
:- Project
9+
: +- BroadcastHashJoin
10+
: :- Project
11+
: : +- Filter
12+
: : +- BroadcastHashJoin
13+
: : :- BroadcastHashJoin
14+
: : : :- CometColumnarToRow
15+
: : : : +- CometBroadcastHashJoin
16+
: : : : :- CometFilter
17+
: : : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.customer
18+
: : : : +- CometBroadcastExchange
19+
: : : : +- CometProject
20+
: : : : +- CometBroadcastHashJoin
21+
: : : : :- CometScan [native_iceberg_compat] parquet spark_catalog.default.store_sales
22+
: : : : : +- SubqueryBroadcast
23+
: : : : : +- BroadcastExchange
24+
: : : : : +- CometColumnarToRow
25+
: : : : : +- CometProject
26+
: : : : : +- CometFilter
27+
: : : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
28+
: : : : +- CometBroadcastExchange
29+
: : : : +- CometProject
30+
: : : : +- CometFilter
31+
: : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
32+
: : : +- BroadcastExchange
33+
: : : +- CometColumnarToRow
34+
: : : +- CometProject
35+
: : : +- CometBroadcastHashJoin
36+
: : : :- CometScan [native_iceberg_compat] parquet spark_catalog.default.web_sales
37+
: : : : +- ReusedSubquery
38+
: : : +- CometBroadcastExchange
39+
: : : +- CometProject
40+
: : : +- CometFilter
41+
: : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
42+
: : +- BroadcastExchange
43+
: : +- CometColumnarToRow
44+
: : +- CometProject
45+
: : +- CometBroadcastHashJoin
46+
: : :- CometScan [native_iceberg_compat] parquet spark_catalog.default.catalog_sales
47+
: : : +- ReusedSubquery
48+
: : +- CometBroadcastExchange
49+
: : +- CometProject
50+
: : +- CometFilter
51+
: : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
52+
: +- BroadcastExchange
53+
: +- CometColumnarToRow
54+
: +- CometProject
55+
: +- CometFilter
56+
: +- CometScan [native_iceberg_compat] parquet spark_catalog.default.customer_address
57+
+- BroadcastExchange
58+
+- CometColumnarToRow
59+
+- CometProject
60+
+- CometFilter
61+
+- CometScan [native_iceberg_compat] parquet spark_catalog.default.customer_demographics
62+
63+
Comet accelerated 35 out of 54 eligible operators (64%). Final plan contains 7 transitions between Spark and Comet.

‎spark/src/test/resources/tpcds-plan-stability/approved-plans-v1_4-spark3_5/q10/extended.txt‎

Lines changed: 63 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,63 @@
1+
TakeOrderedAndProject [COMET: ]
2+
+- HashAggregate
3+
+- CometColumnarToRow
4+
+- CometColumnarExchange
5+
+- HashAggregate
6+
+- Project
7+
+- BroadcastHashJoin
8+
:- Project
9+
: +- BroadcastHashJoin
10+
: :- Project
11+
: : +- Filter
12+
: : +- BroadcastHashJoin
13+
: : :- BroadcastHashJoin
14+
: : : :- CometColumnarToRow
15+
: : : : +- CometBroadcastHashJoin
16+
: : : : :- CometFilter
17+
: : : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.customer
18+
: : : : +- CometBroadcastExchange
19+
: : : : +- CometProject
20+
: : : : +- CometBroadcastHashJoin
21+
: : : : :- CometScan [native_iceberg_compat] parquet spark_catalog.default.store_sales
22+
: : : : : +- SubqueryBroadcast
23+
: : : : : +- BroadcastExchange
24+
: : : : : +- CometColumnarToRow
25+
: : : : : +- CometProject
26+
: : : : : +- CometFilter
27+
: : : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
28+
: : : : +- CometBroadcastExchange
29+
: : : : +- CometProject
30+
: : : : +- CometFilter
31+
: : : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
32+
: : : +- BroadcastExchange
33+
: : : +- CometColumnarToRow
34+
: : : +- CometProject
35+
: : : +- CometBroadcastHashJoin
36+
: : : :- CometScan [native_iceberg_compat] parquet spark_catalog.default.web_sales
37+
: : : : +- ReusedSubquery
38+
: : : +- CometBroadcastExchange
39+
: : : +- CometProject
40+
: : : +- CometFilter
41+
: : : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
42+
: : +- BroadcastExchange
43+
: : +- CometColumnarToRow
44+
: : +- CometProject
45+
: : +- CometBroadcastHashJoin
46+
: : :- CometScan [native_iceberg_compat] parquet spark_catalog.default.catalog_sales
47+
: : : +- ReusedSubquery
48+
: : +- CometBroadcastExchange
49+
: : +- CometProject
50+
: : +- CometFilter
51+
: : +- CometScan [native_iceberg_compat] parquet spark_catalog.default.date_dim
52+
: +- BroadcastExchange
53+
: +- CometColumnarToRow
54+
: +- CometProject
55+
: +- CometFilter
56+
: +- CometScan [native_iceberg_compat] parquet spark_catalog.default.customer_address
57+
+- BroadcastExchange
58+
+- CometColumnarToRow
59+
+- CometProject
60+
+- CometFilter
61+
+- CometScan [native_iceberg_compat] parquet spark_catalog.default.customer_demographics
62+
63+
Comet accelerated 35 out of 54 eligible operators (64%). Final plan contains 7 transitions between Spark and Comet.

0 commit comments

Comments
 (0)