/
simplified.txt
33 lines (33 loc) · 1.75 KB
/
simplified.txt
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
TakeOrderedAndProject [ext_price,brand_id,brand]
WholeStageCodegen (4)
HashAggregate [i_brand,i_brand_id,sum] [sum(UnscaledValue(ss_ext_sales_price)),brand_id,brand,ext_price,sum]
InputAdapter
Exchange [i_brand,i_brand_id] #1
WholeStageCodegen (3)
HashAggregate [i_brand,i_brand_id,ss_ext_sales_price] [sum,sum]
Project [ss_ext_sales_price,i_brand_id,i_brand]
BroadcastHashJoin [ss_item_sk,i_item_sk]
Project [ss_item_sk,ss_ext_sales_price]
BroadcastHashJoin [d_date_sk,ss_sold_date_sk]
InputAdapter
BroadcastExchange #2
WholeStageCodegen (1)
Project [d_date_sk]
Filter [d_moy,d_year,d_date_sk]
ColumnarToRow
InputAdapter
Scan parquet default.date_dim [d_date_sk,d_year,d_moy]
Filter [ss_item_sk]
ColumnarToRow
InputAdapter
Scan parquet default.store_sales [ss_item_sk,ss_ext_sales_price,ss_sold_date_sk]
SubqueryBroadcast [d_date_sk] #1
ReusedExchange [d_date_sk] #2
InputAdapter
BroadcastExchange #3
WholeStageCodegen (2)
Project [i_item_sk,i_brand_id,i_brand]
Filter [i_manager_id,i_item_sk]
ColumnarToRow
InputAdapter
Scan parquet default.item [i_item_sk,i_brand_id,i_brand,i_manager_id]