Skip to content

Commit da7bf5b

Browse files
andygroveandygrove
committed
test: regenerate TPCDS plan-stability golden files
1 parent 5e1e49d commit da7bf5b

282 files changed

Lines changed: 27783 additions & 32419 deletions

File tree

Some content is hidden

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

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

Lines changed: 48 additions & 54 deletions
Original file line numberDiff line numberDiff line change
@@ -1,58 +1,52 @@
1-
TakeOrderedAndProject
2-
+- Project
3-
+- BroadcastHashJoin
4-
:- Project
5-
: +- BroadcastHashJoin
6-
: :- Project
7-
: : +- BroadcastHashJoin
8-
: : :- Filter
9-
: : : +- HashAggregate
10-
: : : +- Exchange
11-
: : : +- HashAggregate
12-
: : : +- Project
13-
: : : +- BroadcastHashJoin
14-
: : : :- Filter
15-
: : : : +- ColumnarToRow
16-
: : : : +- Scan parquet spark_catalog.default.store_returns [COMET: Native DataFusion scan does not support subqueries/dynamic pruning]
17-
: : : : +- SubqueryBroadcast
18-
: : : : +- BroadcastExchange
19-
: : : : +- CometNativeColumnarToRow
20-
: : : : +- CometProject
21-
: : : : +- CometFilter
22-
: : : : +- CometNativeScan parquet spark_catalog.default.date_dim
23-
: : : +- BroadcastExchange
24-
: : : +- CometNativeColumnarToRow
25-
: : : +- CometProject
26-
: : : +- CometFilter
27-
: : : +- CometNativeScan parquet spark_catalog.default.date_dim
28-
: : +- BroadcastExchange
29-
: : +- Filter
30-
: : +- HashAggregate
31-
: : +- Exchange
32-
: : +- HashAggregate
33-
: : +- HashAggregate
34-
: : +- Exchange
35-
: : +- HashAggregate
36-
: : +- Project
37-
: : +- BroadcastHashJoin
38-
: : :- Filter
39-
: : : +- ColumnarToRow
40-
: : : +- Scan parquet spark_catalog.default.store_returns [COMET: Native DataFusion scan does not support subqueries/dynamic pruning]
41-
: : : +- ReusedSubquery
42-
: : +- BroadcastExchange
43-
: : +- CometNativeColumnarToRow
44-
: : +- CometProject
45-
: : +- CometFilter
46-
: : +- CometNativeScan parquet spark_catalog.default.date_dim
47-
: +- BroadcastExchange
48-
: +- CometNativeColumnarToRow
49-
: +- CometProject
50-
: +- CometFilter
51-
: +- CometNativeScan parquet spark_catalog.default.store
52-
+- BroadcastExchange
53-
+- CometNativeColumnarToRow
1+
CometNativeColumnarToRow
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+
: : : : +- CometNativeScan parquet spark_catalog.default.store_returns
17+
: : : : +- CometSubqueryBroadcast
18+
: : : : +- CometBroadcastExchange
19+
: : : : +- CometProject
20+
: : : : +- CometFilter
21+
: : : : +- CometNativeScan parquet spark_catalog.default.date_dim
22+
: : : +- CometBroadcastExchange
23+
: : : +- CometProject
24+
: : : +- CometFilter
25+
: : : +- CometNativeScan parquet spark_catalog.default.date_dim
26+
: : +- CometBroadcastExchange
27+
: : +- CometFilter
28+
: : +- CometHashAggregate
29+
: : +- CometExchange
30+
: : +- CometHashAggregate
31+
: : +- CometHashAggregate
32+
: : +- CometExchange
33+
: : +- CometHashAggregate
34+
: : +- CometProject
35+
: : +- CometBroadcastHashJoin
36+
: : :- CometFilter
37+
: : : +- CometNativeScan parquet spark_catalog.default.store_returns
38+
: : : +- ReusedSubquery
39+
: : +- CometBroadcastExchange
40+
: : +- CometProject
41+
: : +- CometFilter
42+
: : +- CometNativeScan parquet spark_catalog.default.date_dim
43+
: +- CometBroadcastExchange
44+
: +- CometProject
45+
: +- CometFilter
46+
: +- CometNativeScan parquet spark_catalog.default.store
47+
+- CometBroadcastExchange
5448
+- CometProject
5549
+- CometFilter
5650
+- CometNativeScan parquet spark_catalog.default.customer
5751

58-
Comet accelerated 15 out of 49 eligible operators (30%). Final plan contains 7 transitions between Spark and Comet.
52+
Comet accelerated 47 out of 49 eligible operators (95%). Final plan contains 1 transitions between Spark and Comet.

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

Lines changed: 28 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -9,46 +9,41 @@ TakeOrderedAndProject
99
: :- Project
1010
: : +- Filter
1111
: : +- BroadcastHashJoin
12-
: : :- BroadcastHashJoin
13-
: : : :- BroadcastHashJoin
14-
: : : : :- CometNativeColumnarToRow
15-
: : : : : +- CometFilter
16-
: : : : : +- CometNativeScan parquet spark_catalog.default.customer
17-
: : : : +- BroadcastExchange
18-
: : : : +- Project
19-
: : : : +- BroadcastHashJoin
20-
: : : : :- ColumnarToRow
21-
: : : : : +- Scan parquet spark_catalog.default.store_sales [COMET: Native DataFusion scan does not support subqueries/dynamic pruning]
22-
: : : : : +- SubqueryBroadcast
23-
: : : : : +- BroadcastExchange
24-
: : : : : +- CometNativeColumnarToRow
25-
: : : : : +- CometProject
26-
: : : : : +- CometFilter
27-
: : : : : +- CometNativeScan parquet spark_catalog.default.date_dim
28-
: : : : +- BroadcastExchange
29-
: : : : +- CometNativeColumnarToRow
12+
: : :- BroadcastHashJoin [COMET: Unsupported join type ExistenceJoin(exists#1)]
13+
: : : :- CometNativeColumnarToRow
14+
: : : : +- CometBroadcastHashJoin
15+
: : : : :- CometFilter
16+
: : : : : +- CometNativeScan parquet spark_catalog.default.customer
17+
: : : : +- CometBroadcastExchange
18+
: : : : +- CometProject
19+
: : : : +- CometBroadcastHashJoin
20+
: : : : :- CometNativeScan parquet spark_catalog.default.store_sales
21+
: : : : : +- CometSubqueryBroadcast
22+
: : : : : +- CometBroadcastExchange
23+
: : : : : +- CometProject
24+
: : : : : +- CometFilter
25+
: : : : : +- CometNativeScan parquet spark_catalog.default.date_dim
26+
: : : : +- CometBroadcastExchange
3027
: : : : +- CometProject
3128
: : : : +- CometFilter
3229
: : : : +- CometNativeScan parquet spark_catalog.default.date_dim
3330
: : : +- BroadcastExchange
34-
: : : +- Project
35-
: : : +- BroadcastHashJoin
36-
: : : :- ColumnarToRow
37-
: : : : +- Scan parquet spark_catalog.default.web_sales [COMET: Native DataFusion scan does not support subqueries/dynamic pruning]
38-
: : : : +- ReusedSubquery
39-
: : : +- BroadcastExchange
40-
: : : +- CometNativeColumnarToRow
31+
: : : +- CometNativeColumnarToRow
32+
: : : +- CometProject
33+
: : : +- CometBroadcastHashJoin
34+
: : : :- CometNativeScan parquet spark_catalog.default.web_sales
35+
: : : : +- ReusedSubquery
36+
: : : +- CometBroadcastExchange
4137
: : : +- CometProject
4238
: : : +- CometFilter
4339
: : : +- CometNativeScan parquet spark_catalog.default.date_dim
4440
: : +- BroadcastExchange
45-
: : +- Project
46-
: : +- BroadcastHashJoin
47-
: : :- ColumnarToRow
48-
: : : +- Scan parquet spark_catalog.default.catalog_sales [COMET: Native DataFusion scan does not support subqueries/dynamic pruning]
49-
: : : +- ReusedSubquery
50-
: : +- BroadcastExchange
51-
: : +- CometNativeColumnarToRow
41+
: : +- CometNativeColumnarToRow
42+
: : +- CometProject
43+
: : +- CometBroadcastHashJoin
44+
: : :- CometNativeScan parquet spark_catalog.default.catalog_sales
45+
: : : +- ReusedSubquery
46+
: : +- CometBroadcastExchange
5247
: : +- CometProject
5348
: : +- CometFilter
5449
: : +- CometNativeScan parquet spark_catalog.default.date_dim
@@ -63,4 +58,4 @@ TakeOrderedAndProject
6358
+- CometFilter
6459
+- CometNativeScan parquet spark_catalog.default.customer_demographics
6560

66-
Comet accelerated 20 out of 54 eligible operators (37%). Final plan contains 10 transitions between Spark and Comet.
61+
Comet accelerated 35 out of 54 eligible operators (64%). Final plan contains 5 transitions between Spark and Comet.

0 commit comments

Comments
 (0)
⚡