datafusion-comet/spark/src/test/resources/tpcds-plan-stability/approved-plans-v1_4-spark4_0/q6/extended.txt at f813be05569d7ad8b78548c4f0aaa4a948376f24 · apache/datafusion-comet · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
CometNativeColumnarToRow
+- CometTakeOrderedAndProject
   +- CometFilter
      +- CometHashAggregate
         +- CometExchange
            +- CometHashAggregate
               +- CometProject
                  +- CometBroadcastHashJoin
                     :- CometProject
                     :  +- CometBroadcastHashJoin
                     :     :- CometProject
                     :     :  +- CometBroadcastHashJoin
                     :     :     :- CometProject
                     :     :     :  +- CometBroadcastHashJoin
                     :     :     :     :- CometProject
                     :     :     :     :  +- CometFilter
                     :     :     :     :     +- CometNativeScan parquet spark_catalog.default.customer_address
                     :     :     :     +- CometBroadcastExchange
                     :     :     :        +- CometFilter
                     :     :     :           +- CometNativeScan parquet spark_catalog.default.customer
                     :     :     +- CometBroadcastExchange
                     :     :        +- CometFilter
                     :     :           +- CometNativeScan parquet spark_catalog.default.store_sales
                     :     :                 +- CometSubqueryBroadcast
                     :     :                    +- CometBroadcastExchange
                     :     :                       +- CometProject
                     :     :                          +- CometFilter
                     :     :                             :  +- ReusedSubquery
                     :     :                             +- CometNativeScan parquet spark_catalog.default.date_dim
                     :     :                                   +- Subquery
                     :     :                                      +- CometNativeColumnarToRow
                     :     :                                         +- CometHashAggregate
                     :     :                                            +- CometExchange
                     :     :                                               +- CometHashAggregate
                     :     :                                                  +- CometProject
                     :     :                                                     +- CometFilter
                     :     :                                                        +- CometNativeScan parquet spark_catalog.default.date_dim
                     :     +- CometBroadcastExchange
                     :        +- CometProject
                     :           +- CometFilter
                     :              :  +- ReusedSubquery
                     :              +- CometNativeScan parquet spark_catalog.default.date_dim
                     :                    +- ReusedSubquery
                     +- CometBroadcastExchange
                        +- CometProject
                           +- CometBroadcastHashJoin
                              :- CometFilter
                              :  +- CometNativeScan parquet spark_catalog.default.item
                              +- CometBroadcastExchange
                                 +- CometFilter
                                    +- CometHashAggregate
                                       +- CometExchange
                                          +- CometHashAggregate
                                             +- CometProject
                                                +- CometFilter
                                                   +- CometNativeScan parquet spark_catalog.default.item

Comet accelerated 49 out of 54 eligible operators (90%). Final plan contains 2 transitions between Spark and Comet.