Skip to content

Commit

Permalink
Regenerate files
Browse files Browse the repository at this point in the history
  • Loading branch information
@dbaliafroozeh
dbaliafroozeh committed Sep 1, 2020
1 parent f235b53 commit f3a79a3
Show file tree
Hide file tree
Showing 4 changed files with 19 additions and 19 deletions.
12 changes: 6 additions & 6 deletions sql/core/src/test/resources/tpcds-plan-stability/approved-plans-v2_7/q24.sf100/explain.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ Input [8]: [s_store_sk#1, s_store_name#2, s_state#4, s_zip#5, ca_address_sk#7, c

(11) BroadcastExchange
Input [6]: [s_store_sk#1, s_store_name#2, s_state#4, ca_address_sk#7, ca_state#8, ca_country#10]
Arguments: HashedRelationBroadcastMode(List(input[3, int, true], upper(input[5, string, true])),false), [id=#11]
Arguments: HashedRelationBroadcastMode(List(upper(input[5, string, true]), input[3, int, true]),false), [id=#11]

(12) Scan parquet default.customer
Output [5]: [c_customer_sk#12, c_current_addr_sk#13, c_first_name#14, c_last_name#15, c_birth_country#16]
Expand All @@ -112,8 +112,8 @@ Input [5]: [c_customer_sk#12, c_current_addr_sk#13, c_first_name#14, c_last_name
Condition : ((isnotnull(c_customer_sk#12) AND isnotnull(c_current_addr_sk#13)) AND isnotnull(c_birth_country#16))

(15) BroadcastHashJoin [codegen id : 3]
Left keys [2]: [ca_address_sk#7, upper(ca_country#10)]
Right keys [2]: [c_current_addr_sk#13, c_birth_country#16]
Left keys [2]: [upper(ca_country#10), ca_address_sk#7]
Right keys [2]: [c_birth_country#16, c_current_addr_sk#13]
Join condition: None

(16) Project [codegen id : 3]
Expand Down Expand Up @@ -363,7 +363,7 @@ Input [8]: [s_store_sk#1, s_store_name#2, s_state#4, s_zip#5, ca_address_sk#7, c

(58) BroadcastExchange
Input [6]: [s_store_sk#1, s_store_name#2, s_state#4, ca_address_sk#7, ca_state#8, ca_country#10]
Arguments: HashedRelationBroadcastMode(List(input[3, int, true], upper(input[5, string, true])),false), [id=#51]
Arguments: HashedRelationBroadcastMode(List(upper(input[5, string, true]), input[3, int, true]),false), [id=#51]

(59) Scan parquet default.customer
Output [5]: [c_customer_sk#12, c_current_addr_sk#13, c_first_name#14, c_last_name#15, c_birth_country#16]
Expand All @@ -380,8 +380,8 @@ Input [5]: [c_customer_sk#12, c_current_addr_sk#13, c_first_name#14, c_last_name
Condition : ((isnotnull(c_customer_sk#12) AND isnotnull(c_current_addr_sk#13)) AND isnotnull(c_birth_country#16))

(62) BroadcastHashJoin [codegen id : 3]
Left keys [2]: [ca_address_sk#7, upper(ca_country#10)]
Right keys [2]: [c_current_addr_sk#13, c_birth_country#16]
Left keys [2]: [upper(ca_country#10), ca_address_sk#7]
Right keys [2]: [c_birth_country#16, c_current_addr_sk#13]
Join condition: None

(63) Project [codegen id : 3]
Expand Down
4 changes: 2 additions & 2 deletions ...core/src/test/resources/tpcds-plan-stability/approved-plans-v2_7/q24.sf100/simplified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ WholeStageCodegen (12)
BroadcastExchange #14
WholeStageCodegen (3)
Project [s_store_sk,s_store_name,s_state,ca_state,c_customer_sk,c_first_name,c_last_name]
BroadcastHashJoin [ca_address_sk,ca_country,c_current_addr_sk,c_birth_country]
BroadcastHashJoin [ca_country,ca_address_sk,c_birth_country,c_current_addr_sk]
InputAdapter
BroadcastExchange #15
WholeStageCodegen (2)
Expand Down Expand Up @@ -111,7 +111,7 @@ WholeStageCodegen (12)
BroadcastExchange #5
WholeStageCodegen (3)
Project [s_store_sk,s_store_name,s_state,ca_state,c_customer_sk,c_first_name,c_last_name]
BroadcastHashJoin [ca_address_sk,ca_country,c_current_addr_sk,c_birth_country]
BroadcastHashJoin [ca_country,ca_address_sk,c_birth_country,c_current_addr_sk]
InputAdapter
BroadcastExchange #6
WholeStageCodegen (2)
Expand Down
12 changes: 6 additions & 6 deletions sql/core/src/test/resources/tpcds-plan-stability/approved-plans-v2_7/q72.sf100/explain.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -282,11 +282,11 @@ Input [11]: [cs_sold_date_sk#4, cs_item_sk#8, cs_promo_sk#9, cs_order_number#10,

(46) Exchange
Input [7]: [cs_item_sk#8, cs_promo_sk#9, cs_order_number#10, cs_quantity#11, i_item_desc#20, d_date_sk#22, d_week_seq#26]
Arguments: hashpartitioning(cs_item_sk#8, d_date_sk#22, 5), true, [id=#30]
Arguments: hashpartitioning(d_date_sk#22, cs_item_sk#8, 5), true, [id=#30]

(47) Sort [codegen id : 11]
Input [7]: [cs_item_sk#8, cs_promo_sk#9, cs_order_number#10, cs_quantity#11, i_item_desc#20, d_date_sk#22, d_week_seq#26]
Arguments: [cs_item_sk#8 ASC NULLS FIRST, d_date_sk#22 ASC NULLS FIRST], false, 0
Arguments: [d_date_sk#22 ASC NULLS FIRST, cs_item_sk#8 ASC NULLS FIRST], false, 0

(48) Scan parquet default.warehouse
Output [2]: [w_warehouse_sk#31, w_warehouse_name#32]
Expand Down Expand Up @@ -331,15 +331,15 @@ Input [6]: [w_warehouse_sk#31, w_warehouse_name#32, inv_date_sk#34, inv_item_sk#

(57) Exchange
Input [4]: [w_warehouse_name#32, inv_date_sk#34, inv_item_sk#35, inv_quantity_on_hand#37]
Arguments: hashpartitioning(inv_item_sk#35, inv_date_sk#34, 5), true, [id=#38]
Arguments: hashpartitioning(inv_date_sk#34, inv_item_sk#35, 5), true, [id=#38]

(58) Sort [codegen id : 14]
Input [4]: [w_warehouse_name#32, inv_date_sk#34, inv_item_sk#35, inv_quantity_on_hand#37]
Arguments: [inv_item_sk#35 ASC NULLS FIRST, inv_date_sk#34 ASC NULLS FIRST], false, 0
Arguments: [inv_date_sk#34 ASC NULLS FIRST, inv_item_sk#35 ASC NULLS FIRST], false, 0

(59) SortMergeJoin [codegen id : 16]
Left keys [2]: [cs_item_sk#8, d_date_sk#22]
Right keys [2]: [inv_item_sk#35, inv_date_sk#34]
Left keys [2]: [d_date_sk#22, cs_item_sk#8]
Right keys [2]: [inv_date_sk#34, inv_item_sk#35]
Join condition: (inv_quantity_on_hand#37 < cs_quantity#11)

(60) Project [codegen id : 16]
Expand Down
10 changes: 5 additions & 5 deletions ...core/src/test/resources/tpcds-plan-stability/approved-plans-v2_7/q72.sf100/simplified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,12 @@ TakeOrderedAndProject [total_cnt,i_item_desc,w_warehouse_name,d_week_seq,no_prom
Project [cs_item_sk,cs_order_number,w_warehouse_name,i_item_desc,d_week_seq]
BroadcastHashJoin [cs_promo_sk,p_promo_sk]
Project [cs_item_sk,cs_promo_sk,cs_order_number,w_warehouse_name,i_item_desc,d_week_seq]
SortMergeJoin [cs_item_sk,d_date_sk,inv_item_sk,inv_date_sk,inv_quantity_on_hand,cs_quantity]
SortMergeJoin [d_date_sk,cs_item_sk,inv_date_sk,inv_item_sk,inv_quantity_on_hand,cs_quantity]
InputAdapter
WholeStageCodegen (11)
Sort [cs_item_sk,d_date_sk]
Sort [d_date_sk,cs_item_sk]
InputAdapter
Exchange [cs_item_sk,d_date_sk] #3
Exchange [d_date_sk,cs_item_sk] #3
WholeStageCodegen (10)
Project [cs_item_sk,cs_promo_sk,cs_order_number,cs_quantity,i_item_desc,d_date_sk,d_week_seq]
BroadcastHashJoin [cs_sold_date_sk,d_date_sk,d_date,d_date]
Expand Down Expand Up @@ -95,9 +95,9 @@ TakeOrderedAndProject [total_cnt,i_item_desc,w_warehouse_name,d_week_seq,no_prom
Scan parquet default.date_dim [d_date_sk,d_date,d_week_seq,d_year]
InputAdapter
WholeStageCodegen (14)
Sort [inv_item_sk,inv_date_sk]
Sort [inv_date_sk,inv_item_sk]
InputAdapter
Exchange [inv_item_sk,inv_date_sk] #11
Exchange [inv_date_sk,inv_item_sk] #11
WholeStageCodegen (13)
Project [w_warehouse_name,inv_date_sk,inv_item_sk,inv_quantity_on_hand]
BroadcastHashJoin [w_warehouse_sk,inv_warehouse_sk]
Expand Down

0 comments on commit f3a79a3

Please sign in to comment.