Skip to content

Commit

Permalink
Regenerate more files
Browse files Browse the repository at this point in the history
  • Loading branch information
dbaliafroozeh committed Sep 1, 2020
1 parent f3a79a3 commit b0478f3
Show file tree
Hide file tree
Showing 16 changed files with 158 additions and 158 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -171,11 +171,11 @@ Input [8]: [ss_item_sk#2, ss_customer_sk#3, ss_ticket_number#5, ss_quantity#6, s

(26) Exchange
Input [7]: [ss_item_sk#2, ss_customer_sk#3, ss_ticket_number#5, ss_quantity#6, s_state#11, i_item_id#15, i_item_desc#16]
Arguments: hashpartitioning(cast(ss_ticket_number#5 as bigint), cast(ss_item_sk#2 as bigint), cast(ss_customer_sk#3 as bigint), 5), true, [id=#18]
Arguments: hashpartitioning(cast(ss_customer_sk#3 as bigint), cast(ss_item_sk#2 as bigint), cast(ss_ticket_number#5 as bigint), 5), true, [id=#18]

(27) Sort [codegen id : 8]
Input [7]: [ss_item_sk#2, ss_customer_sk#3, ss_ticket_number#5, ss_quantity#6, s_state#11, i_item_id#15, i_item_desc#16]
Arguments: [cast(ss_ticket_number#5 as bigint) ASC NULLS FIRST, cast(ss_item_sk#2 as bigint) ASC NULLS FIRST, cast(ss_customer_sk#3 as bigint) ASC NULLS FIRST], false, 0
Arguments: [cast(ss_customer_sk#3 as bigint) ASC NULLS FIRST, cast(ss_item_sk#2 as bigint) ASC NULLS FIRST, cast(ss_ticket_number#5 as bigint) ASC NULLS FIRST], false, 0

(28) Scan parquet default.date_dim
Output [2]: [d_date_sk#19, d_quarter_name#20]
Expand Down Expand Up @@ -224,15 +224,15 @@ Input [6]: [d_date_sk#19, sr_returned_date_sk#22, sr_item_sk#23, sr_customer_sk#

(38) Exchange
Input [4]: [sr_item_sk#23, sr_customer_sk#24, sr_ticket_number#25, sr_return_quantity#26]
Arguments: hashpartitioning(sr_ticket_number#25, sr_item_sk#23, sr_customer_sk#24, 5), true, [id=#27]
Arguments: hashpartitioning(sr_customer_sk#24, sr_item_sk#23, sr_ticket_number#25, 5), true, [id=#27]

(39) Sort [codegen id : 11]
Input [4]: [sr_item_sk#23, sr_customer_sk#24, sr_ticket_number#25, sr_return_quantity#26]
Arguments: [sr_ticket_number#25 ASC NULLS FIRST, sr_item_sk#23 ASC NULLS FIRST, sr_customer_sk#24 ASC NULLS FIRST], false, 0
Arguments: [sr_customer_sk#24 ASC NULLS FIRST, sr_item_sk#23 ASC NULLS FIRST, sr_ticket_number#25 ASC NULLS FIRST], false, 0

(40) SortMergeJoin [codegen id : 12]
Left keys [3]: [cast(ss_ticket_number#5 as bigint), cast(ss_item_sk#2 as bigint), cast(ss_customer_sk#3 as bigint)]
Right keys [3]: [sr_ticket_number#25, sr_item_sk#23, sr_customer_sk#24]
Left keys [3]: [cast(ss_customer_sk#3 as bigint), cast(ss_item_sk#2 as bigint), cast(ss_ticket_number#5 as bigint)]
Right keys [3]: [sr_customer_sk#24, sr_item_sk#23, sr_ticket_number#25]
Join condition: None

(41) Project [codegen id : 12]
Expand All @@ -241,11 +241,11 @@ Input [11]: [ss_item_sk#2, ss_customer_sk#3, ss_ticket_number#5, ss_quantity#6,

(42) Exchange
Input [7]: [ss_quantity#6, s_state#11, i_item_id#15, i_item_desc#16, sr_item_sk#23, sr_customer_sk#24, sr_return_quantity#26]
Arguments: hashpartitioning(sr_customer_sk#24, sr_item_sk#23, 5), true, [id=#28]
Arguments: hashpartitioning(sr_item_sk#23, sr_customer_sk#24, 5), true, [id=#28]

(43) Sort [codegen id : 13]
Input [7]: [ss_quantity#6, s_state#11, i_item_id#15, i_item_desc#16, sr_item_sk#23, sr_customer_sk#24, sr_return_quantity#26]
Arguments: [sr_customer_sk#24 ASC NULLS FIRST, sr_item_sk#23 ASC NULLS FIRST], false, 0
Arguments: [sr_item_sk#23 ASC NULLS FIRST, sr_customer_sk#24 ASC NULLS FIRST], false, 0

(44) Scan parquet default.catalog_sales
Output [4]: [cs_sold_date_sk#29, cs_bill_customer_sk#30, cs_item_sk#31, cs_quantity#32]
Expand Down Expand Up @@ -275,15 +275,15 @@ Input [5]: [cs_sold_date_sk#29, cs_bill_customer_sk#30, cs_item_sk#31, cs_quanti

(50) Exchange
Input [3]: [cs_bill_customer_sk#30, cs_item_sk#31, cs_quantity#32]
Arguments: hashpartitioning(cast(cs_bill_customer_sk#30 as bigint), cast(cs_item_sk#31 as bigint), 5), true, [id=#34]
Arguments: hashpartitioning(cast(cs_item_sk#31 as bigint), cast(cs_bill_customer_sk#30 as bigint), 5), true, [id=#34]

(51) Sort [codegen id : 16]
Input [3]: [cs_bill_customer_sk#30, cs_item_sk#31, cs_quantity#32]
Arguments: [cast(cs_bill_customer_sk#30 as bigint) ASC NULLS FIRST, cast(cs_item_sk#31 as bigint) ASC NULLS FIRST], false, 0
Arguments: [cast(cs_item_sk#31 as bigint) ASC NULLS FIRST, cast(cs_bill_customer_sk#30 as bigint) ASC NULLS FIRST], false, 0

(52) SortMergeJoin [codegen id : 17]
Left keys [2]: [sr_customer_sk#24, sr_item_sk#23]
Right keys [2]: [cast(cs_bill_customer_sk#30 as bigint), cast(cs_item_sk#31 as bigint)]
Left keys [2]: [sr_item_sk#23, sr_customer_sk#24]
Right keys [2]: [cast(cs_item_sk#31 as bigint), cast(cs_bill_customer_sk#30 as bigint)]
Join condition: None

(53) Project [codegen id : 17]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,20 +6,20 @@ TakeOrderedAndProject [i_item_id,i_item_desc,s_state,store_sales_quantitycount,s
WholeStageCodegen (17)
HashAggregate [i_item_id,i_item_desc,s_state,ss_quantity,sr_return_quantity,cs_quantity] [count,sum,count,n,avg,m2,count,sum,count,n,avg,m2,count,sum,count,n,avg,m2,count,sum,count,n,avg,m2,count,sum,count,n,avg,m2,count,sum,count,n,avg,m2]
Project [ss_quantity,sr_return_quantity,cs_quantity,s_state,i_item_id,i_item_desc]
SortMergeJoin [sr_customer_sk,sr_item_sk,cs_bill_customer_sk,cs_item_sk]
SortMergeJoin [sr_item_sk,sr_customer_sk,cs_item_sk,cs_bill_customer_sk]
InputAdapter
WholeStageCodegen (13)
Sort [sr_customer_sk,sr_item_sk]
Sort [sr_item_sk,sr_customer_sk]
InputAdapter
Exchange [sr_customer_sk,sr_item_sk] #2
Exchange [sr_item_sk,sr_customer_sk] #2
WholeStageCodegen (12)
Project [ss_quantity,s_state,i_item_id,i_item_desc,sr_item_sk,sr_customer_sk,sr_return_quantity]
SortMergeJoin [ss_ticket_number,ss_item_sk,ss_customer_sk,sr_ticket_number,sr_item_sk,sr_customer_sk]
SortMergeJoin [ss_customer_sk,ss_item_sk,ss_ticket_number,sr_customer_sk,sr_item_sk,sr_ticket_number]
InputAdapter
WholeStageCodegen (8)
Sort [ss_ticket_number,ss_item_sk,ss_customer_sk]
Sort [ss_customer_sk,ss_item_sk,ss_ticket_number]
InputAdapter
Exchange [ss_ticket_number,ss_item_sk,ss_customer_sk] #3
Exchange [ss_customer_sk,ss_item_sk,ss_ticket_number] #3
WholeStageCodegen (7)
Project [ss_item_sk,ss_customer_sk,ss_ticket_number,ss_quantity,s_state,i_item_id,i_item_desc]
SortMergeJoin [ss_item_sk,i_item_sk]
Expand Down Expand Up @@ -64,9 +64,9 @@ TakeOrderedAndProject [i_item_id,i_item_desc,s_state,store_sales_quantitycount,s
Scan parquet default.item [i_item_sk,i_item_id,i_item_desc]
InputAdapter
WholeStageCodegen (11)
Sort [sr_ticket_number,sr_item_sk,sr_customer_sk]
Sort [sr_customer_sk,sr_item_sk,sr_ticket_number]
InputAdapter
Exchange [sr_ticket_number,sr_item_sk,sr_customer_sk] #8
Exchange [sr_customer_sk,sr_item_sk,sr_ticket_number] #8
WholeStageCodegen (10)
Project [sr_item_sk,sr_customer_sk,sr_ticket_number,sr_return_quantity]
BroadcastHashJoin [d_date_sk,sr_returned_date_sk]
Expand All @@ -84,9 +84,9 @@ TakeOrderedAndProject [i_item_id,i_item_desc,s_state,store_sales_quantitycount,s
Scan parquet default.store_returns [sr_returned_date_sk,sr_item_sk,sr_customer_sk,sr_ticket_number,sr_return_quantity]
InputAdapter
WholeStageCodegen (16)
Sort [cs_bill_customer_sk,cs_item_sk]
Sort [cs_item_sk,cs_bill_customer_sk]
InputAdapter
Exchange [cs_bill_customer_sk,cs_item_sk] #10
Exchange [cs_item_sk,cs_bill_customer_sk] #10
WholeStageCodegen (15)
Project [cs_bill_customer_sk,cs_item_sk,cs_quantity]
BroadcastHashJoin [cs_sold_date_sk,d_date_sk]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -189,11 +189,11 @@ Input [17]: [ss_item_sk#1, ss_store_sk#3, ss_ticket_number#4, ss_net_paid#5, i_c

(32) Exchange
Input [13]: [ss_item_sk#1, ss_ticket_number#4, ss_net_paid#5, i_current_price#7, i_size#8, i_color#9, i_units#10, i_manager_id#11, c_first_name#15, c_last_name#16, s_store_name#20, s_state#22, ca_state#25]
Arguments: hashpartitioning(cast(ss_ticket_number#4 as bigint), cast(ss_item_sk#1 as bigint), 5), true, [id=#29]
Arguments: hashpartitioning(cast(ss_item_sk#1 as bigint), cast(ss_ticket_number#4 as bigint), 5), true, [id=#29]

(33) Sort [codegen id : 9]
Input [13]: [ss_item_sk#1, ss_ticket_number#4, ss_net_paid#5, i_current_price#7, i_size#8, i_color#9, i_units#10, i_manager_id#11, c_first_name#15, c_last_name#16, s_store_name#20, s_state#22, ca_state#25]
Arguments: [cast(ss_ticket_number#4 as bigint) ASC NULLS FIRST, cast(ss_item_sk#1 as bigint) ASC NULLS FIRST], false, 0
Arguments: [cast(ss_item_sk#1 as bigint) ASC NULLS FIRST, cast(ss_ticket_number#4 as bigint) ASC NULLS FIRST], false, 0

(34) Scan parquet default.store_returns
Output [2]: [sr_item_sk#30, sr_ticket_number#31]
Expand All @@ -211,15 +211,15 @@ Condition : (isnotnull(sr_ticket_number#31) AND isnotnull(sr_item_sk#30))

(37) Exchange
Input [2]: [sr_item_sk#30, sr_ticket_number#31]
Arguments: hashpartitioning(sr_ticket_number#31, sr_item_sk#30, 5), true, [id=#32]
Arguments: hashpartitioning(sr_item_sk#30, sr_ticket_number#31, 5), true, [id=#32]

(38) Sort [codegen id : 11]
Input [2]: [sr_item_sk#30, sr_ticket_number#31]
Arguments: [sr_ticket_number#31 ASC NULLS FIRST, sr_item_sk#30 ASC NULLS FIRST], false, 0
Arguments: [sr_item_sk#30 ASC NULLS FIRST, sr_ticket_number#31 ASC NULLS FIRST], false, 0

(39) SortMergeJoin [codegen id : 12]
Left keys [2]: [cast(ss_ticket_number#4 as bigint), cast(ss_item_sk#1 as bigint)]
Right keys [2]: [sr_ticket_number#31, sr_item_sk#30]
Left keys [2]: [cast(ss_item_sk#1 as bigint), cast(ss_ticket_number#4 as bigint)]
Right keys [2]: [sr_item_sk#30, sr_ticket_number#31]
Join condition: None

(40) Project [codegen id : 12]
Expand Down Expand Up @@ -452,11 +452,11 @@ Input [16]: [s_store_name#20, s_state#22, s_zip#23, ss_item_sk#1, ss_customer_sk

(77) Exchange
Input [14]: [s_store_name#20, s_state#22, s_zip#23, ss_item_sk#1, ss_ticket_number#4, ss_net_paid#5, i_current_price#7, i_size#8, i_color#9, i_units#10, i_manager_id#11, c_first_name#15, c_last_name#16, c_birth_country#17]
Arguments: hashpartitioning(s_zip#23, c_birth_country#17, 5), true, [id=#53]
Arguments: hashpartitioning(c_birth_country#17, s_zip#23, 5), true, [id=#53]

(78) Sort [codegen id : 11]
Input [14]: [s_store_name#20, s_state#22, s_zip#23, ss_item_sk#1, ss_ticket_number#4, ss_net_paid#5, i_current_price#7, i_size#8, i_color#9, i_units#10, i_manager_id#11, c_first_name#15, c_last_name#16, c_birth_country#17]
Arguments: [s_zip#23 ASC NULLS FIRST, c_birth_country#17 ASC NULLS FIRST], false, 0
Arguments: [c_birth_country#17 ASC NULLS FIRST, s_zip#23 ASC NULLS FIRST], false, 0

(79) Scan parquet default.customer_address
Output [3]: [ca_state#25, ca_zip#26, ca_country#27]
Expand All @@ -474,15 +474,15 @@ Condition : (isnotnull(ca_country#27) AND isnotnull(ca_zip#26))

(82) Exchange
Input [3]: [ca_state#25, ca_zip#26, ca_country#27]
Arguments: hashpartitioning(ca_zip#26, upper(ca_country#27), 5), true, [id=#54]
Arguments: hashpartitioning(upper(ca_country#27), ca_zip#26, 5), true, [id=#54]

(83) Sort [codegen id : 13]
Input [3]: [ca_state#25, ca_zip#26, ca_country#27]
Arguments: [ca_zip#26 ASC NULLS FIRST, upper(ca_country#27) ASC NULLS FIRST], false, 0
Arguments: [upper(ca_country#27) ASC NULLS FIRST, ca_zip#26 ASC NULLS FIRST], false, 0

(84) SortMergeJoin [codegen id : 14]
Left keys [2]: [s_zip#23, c_birth_country#17]
Right keys [2]: [ca_zip#26, upper(ca_country#27)]
Left keys [2]: [c_birth_country#17, s_zip#23]
Right keys [2]: [upper(ca_country#27), ca_zip#26]
Join condition: None

(85) Project [codegen id : 14]
Expand All @@ -491,11 +491,11 @@ Input [17]: [s_store_name#20, s_state#22, s_zip#23, ss_item_sk#1, ss_ticket_numb

(86) Exchange
Input [13]: [s_store_name#20, s_state#22, ss_item_sk#1, ss_ticket_number#4, ss_net_paid#5, i_current_price#7, i_size#8, i_color#9, i_units#10, i_manager_id#11, c_first_name#15, c_last_name#16, ca_state#25]
Arguments: hashpartitioning(cast(ss_ticket_number#4 as bigint), cast(ss_item_sk#1 as bigint), 5), true, [id=#55]
Arguments: hashpartitioning(cast(ss_item_sk#1 as bigint), cast(ss_ticket_number#4 as bigint), 5), true, [id=#55]

(87) Sort [codegen id : 15]
Input [13]: [s_store_name#20, s_state#22, ss_item_sk#1, ss_ticket_number#4, ss_net_paid#5, i_current_price#7, i_size#8, i_color#9, i_units#10, i_manager_id#11, c_first_name#15, c_last_name#16, ca_state#25]
Arguments: [cast(ss_ticket_number#4 as bigint) ASC NULLS FIRST, cast(ss_item_sk#1 as bigint) ASC NULLS FIRST], false, 0
Arguments: [cast(ss_item_sk#1 as bigint) ASC NULLS FIRST, cast(ss_ticket_number#4 as bigint) ASC NULLS FIRST], false, 0

(88) Scan parquet default.store_returns
Output [2]: [sr_item_sk#30, sr_ticket_number#31]
Expand All @@ -513,15 +513,15 @@ Condition : (isnotnull(sr_ticket_number#31) AND isnotnull(sr_item_sk#30))

(91) Exchange
Input [2]: [sr_item_sk#30, sr_ticket_number#31]
Arguments: hashpartitioning(sr_ticket_number#31, sr_item_sk#30, 5), true, [id=#56]
Arguments: hashpartitioning(sr_item_sk#30, sr_ticket_number#31, 5), true, [id=#56]

(92) Sort [codegen id : 17]
Input [2]: [sr_item_sk#30, sr_ticket_number#31]
Arguments: [sr_ticket_number#31 ASC NULLS FIRST, sr_item_sk#30 ASC NULLS FIRST], false, 0
Arguments: [sr_item_sk#30 ASC NULLS FIRST, sr_ticket_number#31 ASC NULLS FIRST], false, 0

(93) SortMergeJoin [codegen id : 18]
Left keys [2]: [cast(ss_ticket_number#4 as bigint), cast(ss_item_sk#1 as bigint)]
Right keys [2]: [sr_ticket_number#31, sr_item_sk#30]
Left keys [2]: [cast(ss_item_sk#1 as bigint), cast(ss_ticket_number#4 as bigint)]
Right keys [2]: [sr_item_sk#30, sr_ticket_number#31]
Join condition: None

(94) Project [codegen id : 18]
Expand Down
Loading

0 comments on commit b0478f3

Please sign in to comment.