/
simplified.txt
49 lines (49 loc) · 3.42 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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
TakeOrderedAndProject [lochierarchy,i_category,rank_within_parent,gross_margin,i_class]
WholeStageCodegen (7)
Project [gross_margin,i_category,i_class,lochierarchy,rank_within_parent]
InputAdapter
Window [_w3,_w1,_w2]
WholeStageCodegen (6)
Sort [_w1,_w2,_w3]
InputAdapter
Exchange [_w1,_w2] #1
WholeStageCodegen (5)
HashAggregate [i_category,i_class,spark_grouping_id,sum,sum] [sum(UnscaledValue(ss_net_profit)),sum(UnscaledValue(ss_ext_sales_price)),gross_margin,lochierarchy,_w1,_w2,_w3,sum,sum]
InputAdapter
Exchange [i_category,i_class,spark_grouping_id] #2
WholeStageCodegen (4)
HashAggregate [i_category,i_class,spark_grouping_id,ss_net_profit,ss_ext_sales_price] [sum,sum,sum,sum]
Expand [ss_ext_sales_price,ss_net_profit,i_category,i_class]
Project [ss_ext_sales_price,ss_net_profit,i_category,i_class]
BroadcastHashJoin [ss_store_sk,s_store_sk]
Project [ss_store_sk,ss_ext_sales_price,ss_net_profit,i_class,i_category]
BroadcastHashJoin [ss_item_sk,i_item_sk]
Project [ss_item_sk,ss_store_sk,ss_ext_sales_price,ss_net_profit]
BroadcastHashJoin [ss_sold_date_sk,d_date_sk]
Filter [ss_sold_date_sk,ss_item_sk,ss_store_sk]
ColumnarToRow
InputAdapter
Scan parquet default.store_sales [ss_sold_date_sk,ss_item_sk,ss_store_sk,ss_ext_sales_price,ss_net_profit]
InputAdapter
BroadcastExchange #3
WholeStageCodegen (1)
Project [d_date_sk]
Filter [d_year,d_date_sk]
ColumnarToRow
InputAdapter
Scan parquet default.date_dim [d_date_sk,d_year]
InputAdapter
BroadcastExchange #4
WholeStageCodegen (2)
Filter [i_item_sk]
ColumnarToRow
InputAdapter
Scan parquet default.item [i_item_sk,i_class,i_category]
InputAdapter
BroadcastExchange #5
WholeStageCodegen (3)
Project [s_store_sk]
Filter [s_state,s_store_sk]
ColumnarToRow
InputAdapter
Scan parquet default.store [s_store_sk,s_state]