Skip to content

Commit

Permalink
Update PlanStability
Browse files Browse the repository at this point in the history
  • Loading branch information
viirya committed Mar 14, 2024
1 parent 3732e60 commit f4f0a56
Show file tree
Hide file tree
Showing 22 changed files with 2,918 additions and 3,166 deletions.

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
WholeStageCodegen (9)
WholeStageCodegen (7)
Filter [paid]
Subquery #1
WholeStageCodegen (9)
WholeStageCodegen (7)
HashAggregate [sum,count] [avg(netpaid),(0.05 * avg(netpaid)),sum,count]
InputAdapter
Exchange #9
WholeStageCodegen (8)
WholeStageCodegen (6)
HashAggregate [netpaid] [sum,count,sum,count]
HashAggregate [c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size,sum] [sum(UnscaledValue(ss_net_paid)),netpaid,sum]
InputAdapter
Exchange [c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size] #10
WholeStageCodegen (7)
WholeStageCodegen (5)
HashAggregate [c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size,ss_net_paid] [sum,sum]
Project [ss_net_paid,s_store_name,s_state,i_current_price,i_size,i_color,i_units,i_manager_id,c_first_name,c_last_name,ca_state]
BroadcastHashJoin [c_birth_country,s_zip,ca_country,ca_zip]
Expand All @@ -20,25 +20,19 @@ WholeStageCodegen (9)
BroadcastHashJoin [ss_item_sk,i_item_sk]
Project [ss_item_sk,ss_customer_sk,ss_net_paid,s_store_name,s_state,s_zip]
BroadcastHashJoin [ss_store_sk,s_store_sk]
Project [ss_item_sk,ss_customer_sk,ss_store_sk,ss_net_paid]
SortMergeJoin [ss_ticket_number,ss_item_sk,sr_ticket_number,sr_item_sk]
InputAdapter
WholeStageCodegen (1)
ColumnarToRow
InputAdapter
CometSort [ss_ticket_number,ss_item_sk]
ReusedExchange [ss_item_sk,ss_customer_sk,ss_store_sk,ss_ticket_number,ss_net_paid] #3
InputAdapter
WholeStageCodegen (2)
ColumnarToRow
InputAdapter
CometSort [sr_ticket_number,sr_item_sk]
ReusedExchange [sr_item_sk,sr_ticket_number] #4
ColumnarToRow
InputAdapter
CometProject [ss_item_sk,ss_customer_sk,ss_store_sk,ss_net_paid]
CometSortMergeJoin [ss_ticket_number,ss_item_sk,sr_ticket_number,sr_item_sk]
CometSort [ss_ticket_number,ss_item_sk]
ReusedExchange [ss_item_sk,ss_customer_sk,ss_store_sk,ss_ticket_number,ss_net_paid] #3
CometSort [sr_ticket_number,sr_item_sk]
ReusedExchange [sr_item_sk,sr_ticket_number] #4
InputAdapter
ReusedExchange [s_store_sk,s_store_name,s_state,s_zip] #5
InputAdapter
BroadcastExchange #11
WholeStageCodegen (4)
WholeStageCodegen (2)
ColumnarToRow
InputAdapter
CometFilter [i_item_sk]
Expand All @@ -50,12 +44,12 @@ WholeStageCodegen (9)
HashAggregate [c_last_name,c_first_name,s_store_name,sum,isEmpty] [sum(netpaid),paid,sum,isEmpty]
InputAdapter
Exchange [c_last_name,c_first_name,s_store_name] #1
WholeStageCodegen (8)
WholeStageCodegen (6)
HashAggregate [c_last_name,c_first_name,s_store_name,netpaid] [sum,isEmpty,sum,isEmpty]
HashAggregate [c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size,sum] [sum(UnscaledValue(ss_net_paid)),netpaid,sum]
InputAdapter
Exchange [c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size] #2
WholeStageCodegen (7)
WholeStageCodegen (5)
HashAggregate [c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size,ss_net_paid] [sum,sum]
Project [ss_net_paid,s_store_name,s_state,i_current_price,i_size,i_color,i_units,i_manager_id,c_first_name,c_last_name,ca_state]
BroadcastHashJoin [c_birth_country,s_zip,ca_country,ca_zip]
Expand All @@ -65,51 +59,45 @@ WholeStageCodegen (9)
BroadcastHashJoin [ss_item_sk,i_item_sk]
Project [ss_item_sk,ss_customer_sk,ss_net_paid,s_store_name,s_state,s_zip]
BroadcastHashJoin [ss_store_sk,s_store_sk]
Project [ss_item_sk,ss_customer_sk,ss_store_sk,ss_net_paid]
SortMergeJoin [ss_ticket_number,ss_item_sk,sr_ticket_number,sr_item_sk]
InputAdapter
WholeStageCodegen (1)
ColumnarToRow
InputAdapter
CometSort [ss_ticket_number,ss_item_sk]
CometExchange [ss_ticket_number,ss_item_sk] #3
CometProject [ss_item_sk,ss_customer_sk,ss_store_sk,ss_ticket_number,ss_net_paid]
CometFilter [ss_ticket_number,ss_item_sk,ss_store_sk,ss_customer_sk]
CometScan parquet spark_catalog.default.store_sales [ss_item_sk,ss_customer_sk,ss_store_sk,ss_ticket_number,ss_net_paid,ss_sold_date_sk]
InputAdapter
WholeStageCodegen (2)
ColumnarToRow
InputAdapter
CometSort [sr_ticket_number,sr_item_sk]
CometExchange [sr_ticket_number,sr_item_sk] #4
CometProject [sr_item_sk,sr_ticket_number]
CometFilter [sr_ticket_number,sr_item_sk]
CometScan parquet spark_catalog.default.store_returns [sr_item_sk,sr_ticket_number,sr_returned_date_sk]
ColumnarToRow
InputAdapter
CometProject [ss_item_sk,ss_customer_sk,ss_store_sk,ss_net_paid]
CometSortMergeJoin [ss_ticket_number,ss_item_sk,sr_ticket_number,sr_item_sk]
CometSort [ss_ticket_number,ss_item_sk]
CometExchange [ss_ticket_number,ss_item_sk] #3
CometProject [ss_item_sk,ss_customer_sk,ss_store_sk,ss_ticket_number,ss_net_paid]
CometFilter [ss_ticket_number,ss_item_sk,ss_store_sk,ss_customer_sk]
CometScan parquet spark_catalog.default.store_sales [ss_item_sk,ss_customer_sk,ss_store_sk,ss_ticket_number,ss_net_paid,ss_sold_date_sk]
CometSort [sr_ticket_number,sr_item_sk]
CometExchange [sr_ticket_number,sr_item_sk] #4
CometProject [sr_item_sk,sr_ticket_number]
CometFilter [sr_ticket_number,sr_item_sk]
CometScan parquet spark_catalog.default.store_returns [sr_item_sk,sr_ticket_number,sr_returned_date_sk]
InputAdapter
BroadcastExchange #5
WholeStageCodegen (3)
WholeStageCodegen (1)
ColumnarToRow
InputAdapter
CometProject [s_store_sk,s_store_name,s_state,s_zip]
CometFilter [s_market_id,s_store_sk,s_zip]
CometScan parquet spark_catalog.default.store [s_store_sk,s_store_name,s_market_id,s_state,s_zip]
InputAdapter
BroadcastExchange #6
WholeStageCodegen (4)
WholeStageCodegen (2)
ColumnarToRow
InputAdapter
CometFilter [i_color,i_item_sk]
CometScan parquet spark_catalog.default.item [i_item_sk,i_current_price,i_size,i_color,i_units,i_manager_id]
InputAdapter
BroadcastExchange #7
WholeStageCodegen (5)
WholeStageCodegen (3)
ColumnarToRow
InputAdapter
CometFilter [c_customer_sk,c_birth_country]
CometScan parquet spark_catalog.default.customer [c_customer_sk,c_first_name,c_last_name,c_birth_country]
InputAdapter
BroadcastExchange #8
WholeStageCodegen (6)
WholeStageCodegen (4)
ColumnarToRow
InputAdapter
CometFilter [ca_country,ca_zip]
Expand Down
Loading

0 comments on commit f4f0a56

Please sign in to comment.