Skip to content

Commit

Permalink
Update
Browse files Browse the repository at this point in the history
  • Loading branch information
@viirya
viirya committed Jul 8, 2024
1 parent 2e19986 commit 35071b1
Show file tree
Hide file tree
Showing 270 changed files with 4,121 additions and 4,121 deletions.
22 changes: 11 additions & 11 deletions spark/src/test/resources/tpcds-plan-stability/approved-plans-v1_4-spark3_5/q1/simplified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,22 +13,22 @@ TakeOrderedAndProject [c_customer_id]
WholeStageCodegen (1)
ColumnarToRow
InputAdapter
CometHashAggregate [sr_customer_sk,sr_store_sk,sr_return_amt]
CometHashAggregate [sr_customer_sk,sr_store_sk,sum,sr_return_amt]
CometProject [sr_customer_sk,sr_store_sk,sr_return_amt]
CometBroadcastHashJoin [sr_returned_date_sk,d_date_sk]
CometFilter [sr_store_sk,sr_customer_sk]
CometBroadcastHashJoin [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk,d_date_sk]
CometFilter [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
CometScan parquet spark_catalog.default.store_returns [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
SubqueryBroadcast [d_date_sk] #1
BroadcastExchange #2
WholeStageCodegen (1)
ColumnarToRow
InputAdapter
CometProject [d_date_sk]
CometFilter [d_year,d_date_sk]
CometFilter [d_date_sk,d_year]
CometScan parquet spark_catalog.default.date_dim [d_date_sk,d_year]
CometBroadcastExchange #3
CometBroadcastExchange [d_date_sk] #3
CometProject [d_date_sk]
CometFilter [d_year,d_date_sk]
CometFilter [d_date_sk,d_year]
CometScan parquet spark_catalog.default.date_dim [d_date_sk,d_year]
InputAdapter
BroadcastExchange #4
Expand All @@ -45,10 +45,10 @@ TakeOrderedAndProject [c_customer_id]
WholeStageCodegen (2)
ColumnarToRow
InputAdapter
CometHashAggregate [sr_customer_sk,sr_store_sk,sr_return_amt]
CometHashAggregate [sr_customer_sk,sr_store_sk,sum,sr_return_amt]
CometProject [sr_customer_sk,sr_store_sk,sr_return_amt]
CometBroadcastHashJoin [sr_returned_date_sk,d_date_sk]
CometFilter [sr_store_sk]
CometBroadcastHashJoin [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk,d_date_sk]
CometFilter [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
CometScan parquet spark_catalog.default.store_returns [sr_customer_sk,sr_store_sk,sr_return_amt,sr_returned_date_sk]
ReusedSubquery [d_date_sk] #1
ReusedExchange [d_date_sk] #3
Expand All @@ -58,12 +58,12 @@ TakeOrderedAndProject [c_customer_id]
ColumnarToRow
InputAdapter
CometProject [s_store_sk]
CometFilter [s_state,s_store_sk]
CometFilter [s_store_sk,s_state]
CometScan parquet spark_catalog.default.store [s_store_sk,s_state]
InputAdapter
BroadcastExchange #8
WholeStageCodegen (6)
ColumnarToRow
InputAdapter
CometFilter [c_customer_sk]
CometFilter [c_customer_sk,c_customer_id]
CometScan parquet spark_catalog.default.customer [c_customer_sk,c_customer_id]
22 changes: 11 additions & 11 deletions ...k/src/test/resources/tpcds-plan-stability/approved-plans-v1_4-spark3_5/q10/simplified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,32 +15,32 @@ TakeOrderedAndProject [cd_gender,cd_marital_status,cd_education_status,cd_purcha
BroadcastHashJoin [c_customer_sk,ws_bill_customer_sk]
ColumnarToRow
InputAdapter
CometBroadcastHashJoin [c_customer_sk,ss_customer_sk]
CometFilter [c_current_addr_sk,c_current_cdemo_sk]
CometBroadcastHashJoin [c_customer_sk,c_current_cdemo_sk,c_current_addr_sk,ss_customer_sk]
CometFilter [c_customer_sk,c_current_cdemo_sk,c_current_addr_sk]
CometScan parquet spark_catalog.default.customer [c_customer_sk,c_current_cdemo_sk,c_current_addr_sk]
CometBroadcastExchange #2
CometBroadcastExchange [ss_customer_sk] #2
CometProject [ss_customer_sk]
CometBroadcastHashJoin [ss_sold_date_sk,d_date_sk]
CometBroadcastHashJoin [ss_customer_sk,ss_sold_date_sk,d_date_sk]
CometScan parquet spark_catalog.default.store_sales [ss_customer_sk,ss_sold_date_sk]
SubqueryBroadcast [d_date_sk] #1
BroadcastExchange #3
WholeStageCodegen (1)
ColumnarToRow
InputAdapter
CometProject [d_date_sk]
CometFilter [d_year,d_moy,d_date_sk]
CometFilter [d_date_sk,d_year,d_moy]
CometScan parquet spark_catalog.default.date_dim [d_date_sk,d_year,d_moy]
CometBroadcastExchange #4
CometBroadcastExchange [d_date_sk] #4
CometProject [d_date_sk]
CometFilter [d_year,d_moy,d_date_sk]
CometFilter [d_date_sk,d_year,d_moy]
CometScan parquet spark_catalog.default.date_dim [d_date_sk,d_year,d_moy]
InputAdapter
BroadcastExchange #5
WholeStageCodegen (1)
ColumnarToRow
InputAdapter
CometProject [ws_bill_customer_sk]
CometBroadcastHashJoin [ws_sold_date_sk,d_date_sk]
CometBroadcastHashJoin [ws_bill_customer_sk,ws_sold_date_sk,d_date_sk]
CometScan parquet spark_catalog.default.web_sales [ws_bill_customer_sk,ws_sold_date_sk]
ReusedSubquery [d_date_sk] #1
ReusedExchange [d_date_sk] #4
Expand All @@ -50,7 +50,7 @@ TakeOrderedAndProject [cd_gender,cd_marital_status,cd_education_status,cd_purcha
ColumnarToRow
InputAdapter
CometProject [cs_ship_customer_sk]
CometBroadcastHashJoin [cs_sold_date_sk,d_date_sk]
CometBroadcastHashJoin [cs_ship_customer_sk,cs_sold_date_sk,d_date_sk]
CometScan parquet spark_catalog.default.catalog_sales [cs_ship_customer_sk,cs_sold_date_sk]
ReusedSubquery [d_date_sk] #1
ReusedExchange [d_date_sk] #4
Expand All @@ -60,12 +60,12 @@ TakeOrderedAndProject [cd_gender,cd_marital_status,cd_education_status,cd_purcha
ColumnarToRow
InputAdapter
CometProject [ca_address_sk]
CometFilter [ca_county,ca_address_sk]
CometFilter [ca_address_sk,ca_county]
CometScan parquet spark_catalog.default.customer_address [ca_address_sk,ca_county]
InputAdapter
BroadcastExchange #8
WholeStageCodegen (4)
ColumnarToRow
InputAdapter
CometFilter [cd_demo_sk]
CometFilter [cd_demo_sk,cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count]
CometScan parquet spark_catalog.default.customer_demographics [cd_demo_sk,cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count]
Loading

0 comments on commit 35071b1

Please sign in to comment.