You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jc...@apache.org on 2018/10/13 18:16:08 UTC
[2/6] hive git commit: HIVE-20704: Extend HivePreFilteringRule to
support other functions (Jesus Camacho Rodriguez,
reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/f0b76e24/ql/src/test/results/clientpositive/perf/tez/query85.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/tez/query85.q.out b/ql/src/test/results/clientpositive/perf/tez/query85.q.out
index 2708c72..9724875 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query85.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query85.q.out
@@ -183,16 +183,16 @@ POSTHOOK: Output: hdfs://### HDFS PATH ###
Plan optimized by CBO.
Vertex dependency in root stage
-Map 11 <- Reducer 13 (BROADCAST_EDGE), Reducer 15 (BROADCAST_EDGE)
+Map 12 <- Reducer 11 (BROADCAST_EDGE), Reducer 14 (BROADCAST_EDGE)
Reducer 10 <- Reducer 9 (SIMPLE_EDGE)
-Reducer 13 <- Map 12 (CUSTOM_SIMPLE_EDGE)
-Reducer 15 <- Map 14 (CUSTOM_SIMPLE_EDGE)
-Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 11 (SIMPLE_EDGE)
-Reducer 3 <- Map 12 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE)
-Reducer 4 <- Map 14 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE)
+Reducer 11 <- Map 1 (CUSTOM_SIMPLE_EDGE)
+Reducer 14 <- Map 13 (CUSTOM_SIMPLE_EDGE)
+Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 12 (SIMPLE_EDGE)
+Reducer 3 <- Map 13 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE)
+Reducer 4 <- Map 15 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE)
Reducer 5 <- Map 16 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE)
Reducer 6 <- Map 17 (SIMPLE_EDGE), Reducer 5 (SIMPLE_EDGE)
-Reducer 7 <- Map 17 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE)
+Reducer 7 <- Map 18 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE)
Reducer 8 <- Map 18 (SIMPLE_EDGE), Reducer 7 (SIMPLE_EDGE)
Reducer 9 <- Reducer 8 (SIMPLE_EDGE)
@@ -202,146 +202,144 @@ Stage-0
Stage-1
Reducer 10 vectorized
File Output Operator [FS_244]
- Limit [LIM_243] (rows=100 width=1014)
+ Limit [LIM_243] (rows=100 width=385)
Number of rows:100
- Select Operator [SEL_242] (rows=3666666 width=1014)
+ Select Operator [SEL_242] (rows=1023990 width=385)
Output:["_col0","_col1","_col2","_col3"]
<-Reducer 9 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_241]
- Select Operator [SEL_240] (rows=3666666 width=1014)
+ Select Operator [SEL_240] (rows=1023990 width=385)
Output:["_col4","_col5","_col6","_col7"]
- Group By Operator [GBY_239] (rows=3666666 width=1014)
+ Group By Operator [GBY_239] (rows=1023990 width=385)
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["sum(VALUE._col0)","count(VALUE._col1)","sum(VALUE._col2)","count(VALUE._col3)","sum(VALUE._col4)","count(VALUE._col5)"],keys:KEY._col0
<-Reducer 8 [SIMPLE_EDGE]
SHUFFLE [RS_49]
PartitionCols:_col0
- Group By Operator [GBY_48] (rows=7333332 width=1014)
- Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["sum(_col12)","count(_col12)","sum(_col7)","count(_col7)","sum(_col6)","count(_col6)"],keys:_col19
- Select Operator [SEL_47] (rows=7333332 width=1014)
- Output:["_col6","_col7","_col12","_col19"]
- Filter Operator [FIL_46] (rows=7333332 width=1014)
- predicate:(((_col27) IN ('KY', 'GA', 'NM') and _col14 BETWEEN 100 AND 200) or ((_col27) IN ('MT', 'OR', 'IN') and _col14 BETWEEN 150 AND 300) or ((_col27) IN ('WI', 'MO', 'WV') and _col14 BETWEEN 50 AND 250))
- Merge Join Operator [MERGEJOIN_206] (rows=22000000 width=1014)
- Conds:RS_43._col2=RS_238._col0(Inner),Output:["_col6","_col7","_col12","_col14","_col19","_col27"]
- <-Map 18 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_238]
- PartitionCols:_col0
- Select Operator [SEL_237] (rows=20000000 width=1014)
- Output:["_col0","_col1"]
- Filter Operator [FIL_236] (rows=20000000 width=1014)
- predicate:((ca_country = 'United States') and ca_address_sk is not null)
- TableScan [TS_21] (rows=40000000 width=1014)
- default@customer_address,customer_address,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_state","ca_country"]
- <-Reducer 7 [SIMPLE_EDGE]
- SHUFFLE [RS_43]
- PartitionCols:_col2
- Merge Join Operator [MERGEJOIN_205] (rows=7086373 width=135)
- Conds:RS_40._col3, _col21, _col22=RS_234._col0, _col1, _col2(Inner),Output:["_col2","_col6","_col7","_col12","_col14","_col19"]
- <-Map 17 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_234]
- PartitionCols:_col0, _col1, _col2
- Select Operator [SEL_233] (rows=1861800 width=385)
- Output:["_col0","_col1","_col2"]
- Filter Operator [FIL_232] (rows=1861800 width=385)
- predicate:((cd_education_status) IN ('4 yr Degree', 'Primary', 'Advanced Degree') and (cd_marital_status) IN ('M', 'D', 'U') and cd_demo_sk is not null)
- TableScan [TS_18] (rows=1861800 width=385)
- default@customer_demographics,cd2,Tbl:COMPLETE,Col:NONE,Output:["cd_demo_sk","cd_marital_status","cd_education_status"]
- <-Reducer 6 [SIMPLE_EDGE]
- SHUFFLE [RS_40]
- PartitionCols:_col3, _col21, _col22
- Filter Operator [FIL_39] (rows=6442158 width=135)
- predicate:(((_col21 = 'D') and (_col22 = 'Primary') and _col13 BETWEEN 50 AND 100) or ((_col21 = 'M') and (_col22 = '4 yr Degree') and _col13 BETWEEN 100 AND 150) or ((_col21 = 'U') and (_col22 = 'Advanced Degree') and _col13 BETWEEN 150 AND 200))
- Merge Join Operator [MERGEJOIN_204] (rows=77305913 width=135)
- Conds:RS_36._col1=RS_235._col0(Inner),Output:["_col2","_col3","_col6","_col7","_col12","_col13","_col14","_col19","_col21","_col22"]
- <-Map 17 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_235]
- PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_233]
- <-Reducer 5 [SIMPLE_EDGE]
- SHUFFLE [RS_36]
- PartitionCols:_col1
- Merge Join Operator [MERGEJOIN_203] (rows=70278102 width=135)
- Conds:RS_33._col4=RS_231._col0(Inner),Output:["_col1","_col2","_col3","_col6","_col7","_col12","_col13","_col14","_col19"]
- <-Map 16 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_231]
- PartitionCols:_col0
- Select Operator [SEL_230] (rows=72 width=200)
- Output:["_col0","_col1"]
- Filter Operator [FIL_229] (rows=72 width=200)
- predicate:r_reason_sk is not null
- TableScan [TS_12] (rows=72 width=200)
- default@reason,reason,Tbl:COMPLETE,Col:NONE,Output:["r_reason_sk","r_reason_desc"]
- <-Reducer 4 [SIMPLE_EDGE]
- SHUFFLE [RS_33]
- PartitionCols:_col4
- Merge Join Operator [MERGEJOIN_202] (rows=63889183 width=135)
- Conds:RS_30._col10=RS_220._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col6","_col7","_col12","_col13","_col14"]
- <-Map 14 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_220]
- PartitionCols:_col0
- Select Operator [SEL_219] (rows=4602 width=585)
- Output:["_col0"]
- Filter Operator [FIL_218] (rows=4602 width=585)
- predicate:wp_web_page_sk is not null
- TableScan [TS_9] (rows=4602 width=585)
- default@web_page,web_page,Tbl:COMPLETE,Col:NONE,Output:["wp_web_page_sk"]
- <-Reducer 3 [SIMPLE_EDGE]
- SHUFFLE [RS_30]
- PartitionCols:_col10
- Merge Join Operator [MERGEJOIN_201] (rows=58081075 width=135)
- Conds:RS_27._col8=RS_212._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col6","_col7","_col10","_col12","_col13","_col14"]
- <-Map 12 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_212]
- PartitionCols:_col0
- Select Operator [SEL_211] (rows=36524 width=1119)
- Output:["_col0"]
- Filter Operator [FIL_210] (rows=36524 width=1119)
- predicate:((d_year = 1998) and d_date_sk is not null)
- TableScan [TS_6] (rows=73049 width=1119)
- default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
- <-Reducer 2 [SIMPLE_EDGE]
- SHUFFLE [RS_27]
- PartitionCols:_col8
- Merge Join Operator [MERGEJOIN_200] (rows=52800977 width=135)
- Conds:RS_209._col0, _col5=RS_228._col1, _col3(Inner),Output:["_col1","_col2","_col3","_col4","_col6","_col7","_col8","_col10","_col12","_col13","_col14"]
- <-Map 1 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_209]
- PartitionCols:_col0, _col5
- Select Operator [SEL_208] (rows=14398467 width=92)
- Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"]
- Filter Operator [FIL_207] (rows=14398467 width=92)
- predicate:(wr_item_sk is not null and wr_order_number is not null and wr_reason_sk is not null and wr_refunded_addr_sk is not null and wr_refunded_cdemo_sk is not null and wr_returning_cdemo_sk is not null)
- TableScan [TS_0] (rows=14398467 width=92)
- default@web_returns,web_returns,Tbl:COMPLETE,Col:NONE,Output:["wr_item_sk","wr_refunded_cdemo_sk","wr_refunded_addr_sk","wr_returning_cdemo_sk","wr_reason_sk","wr_order_number","wr_fee","wr_refunded_cash"]
- <-Map 11 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_228]
- PartitionCols:_col1, _col3
- Select Operator [SEL_227] (rows=48000888 width=135)
- Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"]
- Filter Operator [FIL_226] (rows=48000888 width=135)
- predicate:((ws_sales_price BETWEEN 100 AND 150 or ws_sales_price BETWEEN 50 AND 100 or ws_sales_price BETWEEN 150 AND 200) and (ws_sold_date_sk BETWEEN DynamicValue(RS_28_date_dim_d_date_sk_min) AND DynamicValue(RS_28_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_28_date_dim_d_date_sk_bloom_filter))) and (ws_web_page_sk BETWEEN DynamicValue(RS_31_web_page_wp_web_page_sk_min) AND DynamicValue(RS_31_web_page_wp_web_page_sk_max) and in_bloom_filter(ws_web_page_sk, DynamicValue(RS_31_web_page_wp_web_page_sk_bloom_filter))) and ws_item_sk is not null and ws_order_number is not null and ws_sold_date_sk is not null and ws_web_page_sk is not null)
- TableScan [TS_3] (rows=144002668 width=135)
- default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk","ws_web_page_sk","ws_order_number","ws_quantity","ws_sales_price","ws_net_profit"]
- <-Reducer 13 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_217]
- Group By Operator [GBY_216] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
- <-Map 12 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_215]
- Group By Operator [GBY_214] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_213] (rows=36524 width=1119)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_211]
- <-Reducer 15 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_225]
- Group By Operator [GBY_224] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
- <-Map 14 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_223]
- Group By Operator [GBY_222] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_221] (rows=4602 width=585)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_219]
+ Group By Operator [GBY_48] (rows=2047980 width=385)
+ Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["sum(_col5)","count(_col5)","sum(_col17)","count(_col17)","sum(_col16)","count(_col16)"],keys:_col19
+ Merge Join Operator [MERGEJOIN_206] (rows=2047980 width=385)
+ Conds:RS_44._col13, _col24, _col25=RS_237._col0, _col1, _col2(Inner),Output:["_col5","_col16","_col17","_col19"]
+ <-Map 18 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_237]
+ PartitionCols:_col0, _col1, _col2
+ Select Operator [SEL_236] (rows=1861800 width=385)
+ Output:["_col0","_col1","_col2"]
+ Filter Operator [FIL_235] (rows=1861800 width=385)
+ predicate:((cd_education_status) IN ('4 yr Degree', 'Primary', 'Advanced Degree') and (cd_marital_status) IN ('M', 'D', 'U') and cd_demo_sk is not null)
+ TableScan [TS_21] (rows=1861800 width=385)
+ default@customer_demographics,cd2,Tbl:COMPLETE,Col:NONE,Output:["cd_demo_sk","cd_marital_status","cd_education_status"]
+ <-Reducer 7 [SIMPLE_EDGE]
+ SHUFFLE [RS_44]
+ PartitionCols:_col13, _col24, _col25
+ Filter Operator [FIL_43] (rows=787374 width=135)
+ predicate:(((_col24 = 'D') and (_col25 = 'Primary') and _col6 BETWEEN 50 AND 100) or ((_col24 = 'M') and (_col25 = '4 yr Degree') and _col6 BETWEEN 100 AND 150) or ((_col24 = 'U') and (_col25 = 'Advanced Degree') and _col6 BETWEEN 150 AND 200))
+ Merge Join Operator [MERGEJOIN_205] (rows=9448497 width=135)
+ Conds:RS_40._col11=RS_238._col0(Inner),Output:["_col5","_col6","_col13","_col16","_col17","_col19","_col24","_col25"]
+ <-Map 18 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_238]
+ PartitionCols:_col0
+ Please refer to the previous Select Operator [SEL_236]
+ <-Reducer 6 [SIMPLE_EDGE]
+ SHUFFLE [RS_40]
+ PartitionCols:_col11
+ Filter Operator [FIL_39] (rows=8589543 width=135)
+ predicate:(((_col21) IN ('KY', 'GA', 'NM') and _col7 BETWEEN 100 AND 200) or ((_col21) IN ('MT', 'OR', 'IN') and _col7 BETWEEN 150 AND 300) or ((_col21) IN ('WI', 'MO', 'WV') and _col7 BETWEEN 50 AND 250))
+ Merge Join Operator [MERGEJOIN_204] (rows=25768635 width=135)
+ Conds:RS_36._col12=RS_234._col0(Inner),Output:["_col5","_col6","_col7","_col11","_col13","_col16","_col17","_col19","_col21"]
+ <-Map 17 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_234]
+ PartitionCols:_col0
+ Select Operator [SEL_233] (rows=20000000 width=1014)
+ Output:["_col0","_col1"]
+ Filter Operator [FIL_232] (rows=20000000 width=1014)
+ predicate:((ca_country = 'United States') and (ca_state) IN ('KY', 'GA', 'NM', 'MT', 'OR', 'IN', 'WI', 'MO', 'WV') and ca_address_sk is not null)
+ TableScan [TS_15] (rows=40000000 width=1014)
+ default@customer_address,customer_address,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_state","ca_country"]
+ <-Reducer 5 [SIMPLE_EDGE]
+ SHUFFLE [RS_36]
+ PartitionCols:_col12
+ Merge Join Operator [MERGEJOIN_203] (rows=23426032 width=135)
+ Conds:RS_33._col14=RS_231._col0(Inner),Output:["_col5","_col6","_col7","_col11","_col12","_col13","_col16","_col17","_col19"]
+ <-Map 16 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_231]
+ PartitionCols:_col0
+ Select Operator [SEL_230] (rows=72 width=200)
+ Output:["_col0","_col1"]
+ Filter Operator [FIL_229] (rows=72 width=200)
+ predicate:r_reason_sk is not null
+ TableScan [TS_12] (rows=72 width=200)
+ default@reason,reason,Tbl:COMPLETE,Col:NONE,Output:["r_reason_sk","r_reason_desc"]
+ <-Reducer 4 [SIMPLE_EDGE]
+ SHUFFLE [RS_33]
+ PartitionCols:_col14
+ Merge Join Operator [MERGEJOIN_202] (rows=21296393 width=135)
+ Conds:RS_30._col2, _col4=RS_228._col0, _col5(Inner),Output:["_col5","_col6","_col7","_col11","_col12","_col13","_col14","_col16","_col17"]
+ <-Map 15 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_228]
+ PartitionCols:_col0, _col5
+ Select Operator [SEL_227] (rows=14398467 width=92)
+ Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"]
+ Filter Operator [FIL_226] (rows=14398467 width=92)
+ predicate:(wr_item_sk is not null and wr_order_number is not null and wr_reason_sk is not null and wr_refunded_addr_sk is not null and wr_refunded_cdemo_sk is not null and wr_returning_cdemo_sk is not null)
+ TableScan [TS_9] (rows=14398467 width=92)
+ default@web_returns,web_returns,Tbl:COMPLETE,Col:NONE,Output:["wr_item_sk","wr_refunded_cdemo_sk","wr_refunded_addr_sk","wr_returning_cdemo_sk","wr_reason_sk","wr_order_number","wr_fee","wr_refunded_cash"]
+ <-Reducer 3 [SIMPLE_EDGE]
+ SHUFFLE [RS_30]
+ PartitionCols:_col2, _col4
+ Merge Join Operator [MERGEJOIN_201] (rows=19360357 width=135)
+ Conds:RS_27._col1=RS_217._col0(Inner),Output:["_col2","_col4","_col5","_col6","_col7"]
+ <-Map 13 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_217]
+ PartitionCols:_col0
+ Select Operator [SEL_216] (rows=36524 width=1119)
+ Output:["_col0"]
+ Filter Operator [FIL_215] (rows=36524 width=1119)
+ predicate:((d_year = 1998) and d_date_sk is not null)
+ TableScan [TS_6] (rows=73049 width=1119)
+ default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
+ <-Reducer 2 [SIMPLE_EDGE]
+ SHUFFLE [RS_27]
+ PartitionCols:_col1
+ Merge Join Operator [MERGEJOIN_200] (rows=17600325 width=135)
+ Conds:RS_209._col0=RS_225._col2(Inner),Output:["_col1","_col2","_col4","_col5","_col6","_col7"]
+ <-Map 1 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_209]
+ PartitionCols:_col0
+ Select Operator [SEL_208] (rows=4602 width=585)
+ Output:["_col0"]
+ Filter Operator [FIL_207] (rows=4602 width=585)
+ predicate:wp_web_page_sk is not null
+ TableScan [TS_0] (rows=4602 width=585)
+ default@web_page,web_page,Tbl:COMPLETE,Col:NONE,Output:["wp_web_page_sk"]
+ <-Map 12 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_225]
+ PartitionCols:_col2
+ Select Operator [SEL_224] (rows=16000296 width=135)
+ Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"]
+ Filter Operator [FIL_223] (rows=16000296 width=135)
+ predicate:((ws_net_profit BETWEEN 100 AND 200 or ws_net_profit BETWEEN 150 AND 300 or ws_net_profit BETWEEN 50 AND 250) and (ws_sales_price BETWEEN 100 AND 150 or ws_sales_price BETWEEN 50 AND 100 or ws_sales_price BETWEEN 150 AND 200) and (ws_sold_date_sk BETWEEN DynamicValue(RS_28_date_dim_d_date_sk_min) AND DynamicValue(RS_28_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_28_date_dim_d_date_sk_bloom_filter))) and (ws_web_page_sk BETWEEN DynamicValue(RS_24_web_page_wp_web_page_sk_min) AND DynamicValue(RS_24_web_page_wp_web_page_sk_max) and in_bloom_filter(ws_web_page_sk, DynamicValue(RS_24_web_page_wp_web_page_sk_bloom_filter))) and ws_item_sk is not null and ws_order_number is not null and ws_sold_date_sk is not null and ws_web_page_sk is not null)
+ TableScan [TS_3] (rows=144002668 width=135)
+ default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk","ws_web_page_sk","ws_order_number","ws_quantity","ws_sales_price","ws_net_profit"]
+ <-Reducer 11 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_214]
+ Group By Operator [GBY_213] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
+ <-Map 1 [CUSTOM_SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_212]
+ Group By Operator [GBY_211] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
+ Select Operator [SEL_210] (rows=4602 width=585)
+ Output:["_col0"]
+ Please refer to the previous Select Operator [SEL_208]
+ <-Reducer 14 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_222]
+ Group By Operator [GBY_221] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
+ <-Map 13 [CUSTOM_SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_220]
+ Group By Operator [GBY_219] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
+ Select Operator [SEL_218] (rows=36524 width=1119)
+ Output:["_col0"]
+ Please refer to the previous Select Operator [SEL_216]
http://git-wip-us.apache.org/repos/asf/hive/blob/f0b76e24/ql/src/test/results/clientpositive/perf/tez/query88.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/tez/query88.q.out b/ql/src/test/results/clientpositive/perf/tez/query88.q.out
index f515888..2d467f8 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query88.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query88.q.out
@@ -295,37 +295,37 @@ Stage-0
SHUFFLE [RS_44]
PartitionCols:_col2
Merge Join Operator [MERGEJOIN_567] (rows=696954748 width=88)
- Conds:RS_41._col1=RS_642._col0(Inner),Output:["_col2"]
+ Conds:RS_41._col0=RS_642._col0(Inner),Output:["_col2"]
<-Map 44 [SIMPLE_EDGE] vectorized
PARTITION_ONLY_SHUFFLE [RS_642]
PartitionCols:_col0
- Select Operator [SEL_639] (rows=3600 width=107)
+ Select Operator [SEL_633] (rows=14400 width=471)
Output:["_col0"]
- Filter Operator [FIL_638] (rows=3600 width=107)
- predicate:((((hd_dep_count = 3) and (hd_vehicle_count <= 5)) or ((hd_dep_count = 0) and (hd_vehicle_count <= 2)) or ((hd_dep_count = 1) and (hd_vehicle_count <= 3))) and hd_demo_sk is not null)
- TableScan [TS_6] (rows=7200 width=107)
- default@household_demographics,household_demographics,Tbl:COMPLETE,Col:NONE,Output:["hd_demo_sk","hd_dep_count","hd_vehicle_count"]
+ Filter Operator [FIL_625] (rows=14400 width=471)
+ predicate:((t_hour = 12) and (t_minute < 30) and t_time_sk is not null)
+ TableScan [TS_6] (rows=86400 width=471)
+ default@time_dim,time_dim,Tbl:COMPLETE,Col:NONE,Output:["t_time_sk","t_hour","t_minute"]
<-Reducer 9 [SIMPLE_EDGE]
SHUFFLE [RS_41]
- PartitionCols:_col1
+ PartitionCols:_col0
Merge Join Operator [MERGEJOIN_566] (rows=633595212 width=88)
- Conds:RS_723._col0=RS_606._col0(Inner),Output:["_col1","_col2"]
+ Conds:RS_723._col1=RS_592._col0(Inner),Output:["_col0","_col2"]
<-Map 7 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_606]
+ SHUFFLE [RS_592]
PartitionCols:_col0
- Select Operator [SEL_597] (rows=14400 width=471)
+ Select Operator [SEL_589] (rows=2000 width=107)
Output:["_col0"]
- Filter Operator [FIL_589] (rows=14400 width=471)
- predicate:((t_hour = 12) and (t_minute < 30) and t_time_sk is not null)
- TableScan [TS_3] (rows=86400 width=471)
- default@time_dim,time_dim,Tbl:COMPLETE,Col:NONE,Output:["t_time_sk","t_hour","t_minute"]
+ Filter Operator [FIL_588] (rows=2000 width=107)
+ predicate:((((hd_dep_count = 3) and hd_vehicle_count is not null) or ((hd_dep_count = 0) and (hd_vehicle_count <= 2)) or ((hd_dep_count = 1) and (hd_vehicle_count <= 3))) and (hd_dep_count) IN (3, 0, 1) and (hd_vehicle_count <= 5) and hd_demo_sk is not null)
+ TableScan [TS_3] (rows=7200 width=107)
+ default@household_demographics,household_demographics,Tbl:COMPLETE,Col:NONE,Output:["hd_demo_sk","hd_dep_count","hd_vehicle_count"]
<-Map 62 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_723]
- PartitionCols:_col0
+ PartitionCols:_col1
Select Operator [SEL_722] (rows=575995635 width=88)
Output:["_col0","_col1","_col2"]
Filter Operator [FIL_721] (rows=575995635 width=88)
- predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_42_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_42_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_42_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_39_time_dim_t_time_sk_min) AND DynamicValue(RS_39_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_39_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_45_store_s_store_sk_min) AND DynamicValue(RS_45_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_45_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
+ predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_39_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_39_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_39_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_42_time_dim_t_time_sk_min) AND DynamicValue(RS_42_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_42_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_45_store_s_store_sk_min) AND DynamicValue(RS_45_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_45_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
TableScan [TS_26] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_time_sk","ss_hdemo_sk","ss_store_sk"]
<-Reducer 13 [BROADCAST_EDGE] vectorized
@@ -333,12 +333,12 @@ Stage-0
Group By Operator [GBY_715] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 7 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_629]
- Group By Operator [GBY_621] (rows=1 width=12)
+ SHUFFLE [RS_615]
+ Group By Operator [GBY_607] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_607] (rows=14400 width=471)
+ Select Operator [SEL_593] (rows=2000 width=107)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_597]
+ Please refer to the previous Select Operator [SEL_589]
<-Reducer 46 [BROADCAST_EDGE] vectorized
BROADCAST [RS_718]
Group By Operator [GBY_717] (rows=1 width=12)
@@ -347,9 +347,9 @@ Stage-0
PARTITION_ONLY_SHUFFLE [RS_665]
Group By Operator [GBY_657] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_643] (rows=3600 width=107)
+ Select Operator [SEL_643] (rows=14400 width=471)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_639]
+ Please refer to the previous Select Operator [SEL_633]
<-Reducer 55 [BROADCAST_EDGE] vectorized
BROADCAST [RS_720]
Group By Operator [GBY_719] (rows=1 width=12)
@@ -379,31 +379,31 @@ Stage-0
SHUFFLE [RS_70]
PartitionCols:_col2
Merge Join Operator [MERGEJOIN_570] (rows=696954748 width=88)
- Conds:RS_67._col1=RS_644._col0(Inner),Output:["_col2"]
+ Conds:RS_67._col0=RS_644._col0(Inner),Output:["_col2"]
<-Map 44 [SIMPLE_EDGE] vectorized
PARTITION_ONLY_SHUFFLE [RS_644]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_639]
+ Select Operator [SEL_634] (rows=14400 width=471)
+ Output:["_col0"]
+ Filter Operator [FIL_626] (rows=14400 width=471)
+ predicate:((t_hour = 11) and (t_minute >= 30) and t_time_sk is not null)
+ Please refer to the previous TableScan [TS_6]
<-Reducer 14 [SIMPLE_EDGE]
SHUFFLE [RS_67]
- PartitionCols:_col1
+ PartitionCols:_col0
Merge Join Operator [MERGEJOIN_569] (rows=633595212 width=88)
- Conds:RS_734._col0=RS_608._col0(Inner),Output:["_col1","_col2"]
+ Conds:RS_734._col1=RS_594._col0(Inner),Output:["_col0","_col2"]
<-Map 7 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_608]
+ SHUFFLE [RS_594]
PartitionCols:_col0
- Select Operator [SEL_598] (rows=14400 width=471)
- Output:["_col0"]
- Filter Operator [FIL_590] (rows=14400 width=471)
- predicate:((t_hour = 11) and (t_minute >= 30) and t_time_sk is not null)
- Please refer to the previous TableScan [TS_3]
+ Please refer to the previous Select Operator [SEL_589]
<-Map 63 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_734]
- PartitionCols:_col0
+ PartitionCols:_col1
Select Operator [SEL_733] (rows=575995635 width=88)
Output:["_col0","_col1","_col2"]
Filter Operator [FIL_732] (rows=575995635 width=88)
- predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_68_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_68_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_68_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_65_time_dim_t_time_sk_min) AND DynamicValue(RS_65_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_65_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_71_store_s_store_sk_min) AND DynamicValue(RS_71_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_71_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
+ predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_65_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_65_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_65_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_68_time_dim_t_time_sk_min) AND DynamicValue(RS_68_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_68_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_71_store_s_store_sk_min) AND DynamicValue(RS_71_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_71_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
TableScan [TS_52] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_time_sk","ss_hdemo_sk","ss_store_sk"]
<-Reducer 18 [BROADCAST_EDGE] vectorized
@@ -411,12 +411,12 @@ Stage-0
Group By Operator [GBY_726] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 7 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_630]
- Group By Operator [GBY_622] (rows=1 width=12)
+ SHUFFLE [RS_616]
+ Group By Operator [GBY_608] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_609] (rows=14400 width=471)
+ Select Operator [SEL_595] (rows=2000 width=107)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_598]
+ Please refer to the previous Select Operator [SEL_589]
<-Reducer 47 [BROADCAST_EDGE] vectorized
BROADCAST [RS_729]
Group By Operator [GBY_728] (rows=1 width=12)
@@ -425,9 +425,9 @@ Stage-0
PARTITION_ONLY_SHUFFLE [RS_666]
Group By Operator [GBY_658] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_645] (rows=3600 width=107)
+ Select Operator [SEL_645] (rows=14400 width=471)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_639]
+ Please refer to the previous Select Operator [SEL_634]
<-Reducer 56 [BROADCAST_EDGE] vectorized
BROADCAST [RS_731]
Group By Operator [GBY_730] (rows=1 width=12)
@@ -457,31 +457,31 @@ Stage-0
SHUFFLE [RS_96]
PartitionCols:_col2
Merge Join Operator [MERGEJOIN_573] (rows=696954748 width=88)
- Conds:RS_93._col1=RS_646._col0(Inner),Output:["_col2"]
+ Conds:RS_93._col0=RS_646._col0(Inner),Output:["_col2"]
<-Map 44 [SIMPLE_EDGE] vectorized
PARTITION_ONLY_SHUFFLE [RS_646]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_639]
+ Select Operator [SEL_635] (rows=14400 width=471)
+ Output:["_col0"]
+ Filter Operator [FIL_627] (rows=14400 width=471)
+ predicate:((t_hour = 11) and (t_minute < 30) and t_time_sk is not null)
+ Please refer to the previous TableScan [TS_6]
<-Reducer 19 [SIMPLE_EDGE]
SHUFFLE [RS_93]
- PartitionCols:_col1
+ PartitionCols:_col0
Merge Join Operator [MERGEJOIN_572] (rows=633595212 width=88)
- Conds:RS_745._col0=RS_610._col0(Inner),Output:["_col1","_col2"]
+ Conds:RS_745._col1=RS_596._col0(Inner),Output:["_col0","_col2"]
<-Map 7 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_610]
+ SHUFFLE [RS_596]
PartitionCols:_col0
- Select Operator [SEL_599] (rows=14400 width=471)
- Output:["_col0"]
- Filter Operator [FIL_591] (rows=14400 width=471)
- predicate:((t_hour = 11) and (t_minute < 30) and t_time_sk is not null)
- Please refer to the previous TableScan [TS_3]
+ Please refer to the previous Select Operator [SEL_589]
<-Map 64 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_745]
- PartitionCols:_col0
+ PartitionCols:_col1
Select Operator [SEL_744] (rows=575995635 width=88)
Output:["_col0","_col1","_col2"]
Filter Operator [FIL_743] (rows=575995635 width=88)
- predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_94_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_94_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_94_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_91_time_dim_t_time_sk_min) AND DynamicValue(RS_91_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_91_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_97_store_s_store_sk_min) AND DynamicValue(RS_97_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_97_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
+ predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_91_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_91_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_91_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_94_time_dim_t_time_sk_min) AND DynamicValue(RS_94_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_94_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_97_store_s_store_sk_min) AND DynamicValue(RS_97_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_97_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
TableScan [TS_78] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_time_sk","ss_hdemo_sk","ss_store_sk"]
<-Reducer 23 [BROADCAST_EDGE] vectorized
@@ -489,12 +489,12 @@ Stage-0
Group By Operator [GBY_737] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 7 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_631]
- Group By Operator [GBY_623] (rows=1 width=12)
+ SHUFFLE [RS_617]
+ Group By Operator [GBY_609] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_611] (rows=14400 width=471)
+ Select Operator [SEL_597] (rows=2000 width=107)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_599]
+ Please refer to the previous Select Operator [SEL_589]
<-Reducer 48 [BROADCAST_EDGE] vectorized
BROADCAST [RS_740]
Group By Operator [GBY_739] (rows=1 width=12)
@@ -503,9 +503,9 @@ Stage-0
PARTITION_ONLY_SHUFFLE [RS_667]
Group By Operator [GBY_659] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_647] (rows=3600 width=107)
+ Select Operator [SEL_647] (rows=14400 width=471)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_639]
+ Please refer to the previous Select Operator [SEL_635]
<-Reducer 57 [BROADCAST_EDGE] vectorized
BROADCAST [RS_742]
Group By Operator [GBY_741] (rows=1 width=12)
@@ -535,31 +535,31 @@ Stage-0
SHUFFLE [RS_122]
PartitionCols:_col2
Merge Join Operator [MERGEJOIN_576] (rows=696954748 width=88)
- Conds:RS_119._col1=RS_648._col0(Inner),Output:["_col2"]
+ Conds:RS_119._col0=RS_648._col0(Inner),Output:["_col2"]
<-Map 44 [SIMPLE_EDGE] vectorized
PARTITION_ONLY_SHUFFLE [RS_648]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_639]
+ Select Operator [SEL_636] (rows=14400 width=471)
+ Output:["_col0"]
+ Filter Operator [FIL_628] (rows=14400 width=471)
+ predicate:((t_hour = 10) and (t_minute >= 30) and t_time_sk is not null)
+ Please refer to the previous TableScan [TS_6]
<-Reducer 24 [SIMPLE_EDGE]
SHUFFLE [RS_119]
- PartitionCols:_col1
+ PartitionCols:_col0
Merge Join Operator [MERGEJOIN_575] (rows=633595212 width=88)
- Conds:RS_756._col0=RS_612._col0(Inner),Output:["_col1","_col2"]
+ Conds:RS_756._col1=RS_598._col0(Inner),Output:["_col0","_col2"]
<-Map 7 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_612]
+ SHUFFLE [RS_598]
PartitionCols:_col0
- Select Operator [SEL_600] (rows=14400 width=471)
- Output:["_col0"]
- Filter Operator [FIL_592] (rows=14400 width=471)
- predicate:((t_hour = 10) and (t_minute >= 30) and t_time_sk is not null)
- Please refer to the previous TableScan [TS_3]
+ Please refer to the previous Select Operator [SEL_589]
<-Map 65 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_756]
- PartitionCols:_col0
+ PartitionCols:_col1
Select Operator [SEL_755] (rows=575995635 width=88)
Output:["_col0","_col1","_col2"]
Filter Operator [FIL_754] (rows=575995635 width=88)
- predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_120_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_120_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_120_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_117_time_dim_t_time_sk_min) AND DynamicValue(RS_117_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_117_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_123_store_s_store_sk_min) AND DynamicValue(RS_123_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_123_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
+ predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_117_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_117_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_117_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_120_time_dim_t_time_sk_min) AND DynamicValue(RS_120_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_120_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_123_store_s_store_sk_min) AND DynamicValue(RS_123_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_123_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
TableScan [TS_104] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_time_sk","ss_hdemo_sk","ss_store_sk"]
<-Reducer 28 [BROADCAST_EDGE] vectorized
@@ -567,12 +567,12 @@ Stage-0
Group By Operator [GBY_748] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 7 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_632]
- Group By Operator [GBY_624] (rows=1 width=12)
+ SHUFFLE [RS_618]
+ Group By Operator [GBY_610] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_613] (rows=14400 width=471)
+ Select Operator [SEL_599] (rows=2000 width=107)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_600]
+ Please refer to the previous Select Operator [SEL_589]
<-Reducer 49 [BROADCAST_EDGE] vectorized
BROADCAST [RS_751]
Group By Operator [GBY_750] (rows=1 width=12)
@@ -581,9 +581,9 @@ Stage-0
PARTITION_ONLY_SHUFFLE [RS_668]
Group By Operator [GBY_660] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_649] (rows=3600 width=107)
+ Select Operator [SEL_649] (rows=14400 width=471)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_639]
+ Please refer to the previous Select Operator [SEL_636]
<-Reducer 58 [BROADCAST_EDGE] vectorized
BROADCAST [RS_753]
Group By Operator [GBY_752] (rows=1 width=12)
@@ -613,31 +613,31 @@ Stage-0
SHUFFLE [RS_148]
PartitionCols:_col2
Merge Join Operator [MERGEJOIN_579] (rows=696954748 width=88)
- Conds:RS_145._col1=RS_650._col0(Inner),Output:["_col2"]
+ Conds:RS_145._col0=RS_650._col0(Inner),Output:["_col2"]
<-Map 44 [SIMPLE_EDGE] vectorized
PARTITION_ONLY_SHUFFLE [RS_650]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_639]
+ Select Operator [SEL_637] (rows=14400 width=471)
+ Output:["_col0"]
+ Filter Operator [FIL_629] (rows=14400 width=471)
+ predicate:((t_hour = 10) and (t_minute < 30) and t_time_sk is not null)
+ Please refer to the previous TableScan [TS_6]
<-Reducer 29 [SIMPLE_EDGE]
SHUFFLE [RS_145]
- PartitionCols:_col1
+ PartitionCols:_col0
Merge Join Operator [MERGEJOIN_578] (rows=633595212 width=88)
- Conds:RS_767._col0=RS_614._col0(Inner),Output:["_col1","_col2"]
+ Conds:RS_767._col1=RS_600._col0(Inner),Output:["_col0","_col2"]
<-Map 7 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_614]
+ SHUFFLE [RS_600]
PartitionCols:_col0
- Select Operator [SEL_601] (rows=14400 width=471)
- Output:["_col0"]
- Filter Operator [FIL_593] (rows=14400 width=471)
- predicate:((t_hour = 10) and (t_minute < 30) and t_time_sk is not null)
- Please refer to the previous TableScan [TS_3]
+ Please refer to the previous Select Operator [SEL_589]
<-Map 66 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_767]
- PartitionCols:_col0
+ PartitionCols:_col1
Select Operator [SEL_766] (rows=575995635 width=88)
Output:["_col0","_col1","_col2"]
Filter Operator [FIL_765] (rows=575995635 width=88)
- predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_146_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_146_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_146_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_143_time_dim_t_time_sk_min) AND DynamicValue(RS_143_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_143_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_149_store_s_store_sk_min) AND DynamicValue(RS_149_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_149_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
+ predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_143_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_143_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_143_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_146_time_dim_t_time_sk_min) AND DynamicValue(RS_146_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_146_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_149_store_s_store_sk_min) AND DynamicValue(RS_149_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_149_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
TableScan [TS_130] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_time_sk","ss_hdemo_sk","ss_store_sk"]
<-Reducer 33 [BROADCAST_EDGE] vectorized
@@ -645,12 +645,12 @@ Stage-0
Group By Operator [GBY_759] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 7 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_633]
- Group By Operator [GBY_625] (rows=1 width=12)
+ SHUFFLE [RS_619]
+ Group By Operator [GBY_611] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_615] (rows=14400 width=471)
+ Select Operator [SEL_601] (rows=2000 width=107)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_601]
+ Please refer to the previous Select Operator [SEL_589]
<-Reducer 50 [BROADCAST_EDGE] vectorized
BROADCAST [RS_762]
Group By Operator [GBY_761] (rows=1 width=12)
@@ -659,9 +659,9 @@ Stage-0
PARTITION_ONLY_SHUFFLE [RS_669]
Group By Operator [GBY_661] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_651] (rows=3600 width=107)
+ Select Operator [SEL_651] (rows=14400 width=471)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_639]
+ Please refer to the previous Select Operator [SEL_637]
<-Reducer 59 [BROADCAST_EDGE] vectorized
BROADCAST [RS_764]
Group By Operator [GBY_763] (rows=1 width=12)
@@ -691,31 +691,31 @@ Stage-0
SHUFFLE [RS_174]
PartitionCols:_col2
Merge Join Operator [MERGEJOIN_582] (rows=696954748 width=88)
- Conds:RS_171._col1=RS_652._col0(Inner),Output:["_col2"]
+ Conds:RS_171._col0=RS_652._col0(Inner),Output:["_col2"]
<-Map 44 [SIMPLE_EDGE] vectorized
PARTITION_ONLY_SHUFFLE [RS_652]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_639]
+ Select Operator [SEL_638] (rows=14400 width=471)
+ Output:["_col0"]
+ Filter Operator [FIL_630] (rows=14400 width=471)
+ predicate:((t_hour = 9) and (t_minute >= 30) and t_time_sk is not null)
+ Please refer to the previous TableScan [TS_6]
<-Reducer 34 [SIMPLE_EDGE]
SHUFFLE [RS_171]
- PartitionCols:_col1
+ PartitionCols:_col0
Merge Join Operator [MERGEJOIN_581] (rows=633595212 width=88)
- Conds:RS_778._col0=RS_616._col0(Inner),Output:["_col1","_col2"]
+ Conds:RS_778._col1=RS_602._col0(Inner),Output:["_col0","_col2"]
<-Map 7 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_616]
+ SHUFFLE [RS_602]
PartitionCols:_col0
- Select Operator [SEL_602] (rows=14400 width=471)
- Output:["_col0"]
- Filter Operator [FIL_594] (rows=14400 width=471)
- predicate:((t_hour = 9) and (t_minute >= 30) and t_time_sk is not null)
- Please refer to the previous TableScan [TS_3]
+ Please refer to the previous Select Operator [SEL_589]
<-Map 67 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_778]
- PartitionCols:_col0
+ PartitionCols:_col1
Select Operator [SEL_777] (rows=575995635 width=88)
Output:["_col0","_col1","_col2"]
Filter Operator [FIL_776] (rows=575995635 width=88)
- predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_172_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_172_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_172_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_169_time_dim_t_time_sk_min) AND DynamicValue(RS_169_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_169_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_175_store_s_store_sk_min) AND DynamicValue(RS_175_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_175_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
+ predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_169_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_169_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_169_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_172_time_dim_t_time_sk_min) AND DynamicValue(RS_172_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_172_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_175_store_s_store_sk_min) AND DynamicValue(RS_175_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_175_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
TableScan [TS_156] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_time_sk","ss_hdemo_sk","ss_store_sk"]
<-Reducer 38 [BROADCAST_EDGE] vectorized
@@ -723,12 +723,12 @@ Stage-0
Group By Operator [GBY_770] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 7 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_634]
- Group By Operator [GBY_626] (rows=1 width=12)
+ SHUFFLE [RS_620]
+ Group By Operator [GBY_612] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_617] (rows=14400 width=471)
+ Select Operator [SEL_603] (rows=2000 width=107)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_602]
+ Please refer to the previous Select Operator [SEL_589]
<-Reducer 51 [BROADCAST_EDGE] vectorized
BROADCAST [RS_773]
Group By Operator [GBY_772] (rows=1 width=12)
@@ -737,9 +737,9 @@ Stage-0
PARTITION_ONLY_SHUFFLE [RS_670]
Group By Operator [GBY_662] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_653] (rows=3600 width=107)
+ Select Operator [SEL_653] (rows=14400 width=471)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_639]
+ Please refer to the previous Select Operator [SEL_638]
<-Reducer 60 [BROADCAST_EDGE] vectorized
BROADCAST [RS_775]
Group By Operator [GBY_774] (rows=1 width=12)
@@ -769,31 +769,31 @@ Stage-0
SHUFFLE [RS_200]
PartitionCols:_col2
Merge Join Operator [MERGEJOIN_585] (rows=696954748 width=88)
- Conds:RS_197._col1=RS_654._col0(Inner),Output:["_col2"]
+ Conds:RS_197._col0=RS_654._col0(Inner),Output:["_col2"]
<-Map 44 [SIMPLE_EDGE] vectorized
PARTITION_ONLY_SHUFFLE [RS_654]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_639]
+ Select Operator [SEL_639] (rows=14400 width=471)
+ Output:["_col0"]
+ Filter Operator [FIL_631] (rows=14400 width=471)
+ predicate:((t_hour = 9) and (t_minute < 30) and t_time_sk is not null)
+ Please refer to the previous TableScan [TS_6]
<-Reducer 39 [SIMPLE_EDGE]
SHUFFLE [RS_197]
- PartitionCols:_col1
+ PartitionCols:_col0
Merge Join Operator [MERGEJOIN_584] (rows=633595212 width=88)
- Conds:RS_789._col0=RS_618._col0(Inner),Output:["_col1","_col2"]
+ Conds:RS_789._col1=RS_604._col0(Inner),Output:["_col0","_col2"]
<-Map 7 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_618]
+ SHUFFLE [RS_604]
PartitionCols:_col0
- Select Operator [SEL_603] (rows=14400 width=471)
- Output:["_col0"]
- Filter Operator [FIL_595] (rows=14400 width=471)
- predicate:((t_hour = 9) and (t_minute < 30) and t_time_sk is not null)
- Please refer to the previous TableScan [TS_3]
+ Please refer to the previous Select Operator [SEL_589]
<-Map 68 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_789]
- PartitionCols:_col0
+ PartitionCols:_col1
Select Operator [SEL_788] (rows=575995635 width=88)
Output:["_col0","_col1","_col2"]
Filter Operator [FIL_787] (rows=575995635 width=88)
- predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_198_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_198_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_198_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_195_time_dim_t_time_sk_min) AND DynamicValue(RS_195_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_195_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_201_store_s_store_sk_min) AND DynamicValue(RS_201_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_201_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
+ predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_195_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_195_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_195_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_198_time_dim_t_time_sk_min) AND DynamicValue(RS_198_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_198_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_201_store_s_store_sk_min) AND DynamicValue(RS_201_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_201_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
TableScan [TS_182] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_time_sk","ss_hdemo_sk","ss_store_sk"]
<-Reducer 43 [BROADCAST_EDGE] vectorized
@@ -801,12 +801,12 @@ Stage-0
Group By Operator [GBY_781] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 7 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_635]
- Group By Operator [GBY_627] (rows=1 width=12)
+ SHUFFLE [RS_621]
+ Group By Operator [GBY_613] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_619] (rows=14400 width=471)
+ Select Operator [SEL_605] (rows=2000 width=107)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_603]
+ Please refer to the previous Select Operator [SEL_589]
<-Reducer 52 [BROADCAST_EDGE] vectorized
BROADCAST [RS_784]
Group By Operator [GBY_783] (rows=1 width=12)
@@ -815,7 +815,7 @@ Stage-0
PARTITION_ONLY_SHUFFLE [RS_671]
Group By Operator [GBY_663] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_655] (rows=3600 width=107)
+ Select Operator [SEL_655] (rows=14400 width=471)
Output:["_col0"]
Please refer to the previous Select Operator [SEL_639]
<-Reducer 61 [BROADCAST_EDGE] vectorized
@@ -847,31 +847,31 @@ Stage-0
SHUFFLE [RS_18]
PartitionCols:_col2
Merge Join Operator [MERGEJOIN_564] (rows=696954748 width=88)
- Conds:RS_15._col1=RS_640._col0(Inner),Output:["_col2"]
+ Conds:RS_15._col0=RS_640._col0(Inner),Output:["_col2"]
<-Map 44 [SIMPLE_EDGE] vectorized
PARTITION_ONLY_SHUFFLE [RS_640]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_639]
+ Select Operator [SEL_632] (rows=14400 width=471)
+ Output:["_col0"]
+ Filter Operator [FIL_624] (rows=14400 width=471)
+ predicate:((t_hour = 8) and (t_minute >= 30) and t_time_sk is not null)
+ Please refer to the previous TableScan [TS_6]
<-Reducer 2 [SIMPLE_EDGE]
SHUFFLE [RS_15]
- PartitionCols:_col1
+ PartitionCols:_col0
Merge Join Operator [MERGEJOIN_563] (rows=633595212 width=88)
- Conds:RS_712._col0=RS_604._col0(Inner),Output:["_col1","_col2"]
+ Conds:RS_712._col1=RS_590._col0(Inner),Output:["_col0","_col2"]
<-Map 7 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_604]
+ SHUFFLE [RS_590]
PartitionCols:_col0
- Select Operator [SEL_596] (rows=14400 width=471)
- Output:["_col0"]
- Filter Operator [FIL_588] (rows=14400 width=471)
- predicate:((t_hour = 8) and (t_minute >= 30) and t_time_sk is not null)
- Please refer to the previous TableScan [TS_3]
+ Please refer to the previous Select Operator [SEL_589]
<-Map 1 [SIMPLE_EDGE] vectorized
SHUFFLE [RS_712]
- PartitionCols:_col0
+ PartitionCols:_col1
Select Operator [SEL_711] (rows=575995635 width=88)
Output:["_col0","_col1","_col2"]
Filter Operator [FIL_710] (rows=575995635 width=88)
- predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_16_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_16_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_16_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_13_time_dim_t_time_sk_min) AND DynamicValue(RS_13_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_13_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_19_store_s_store_sk_min) AND DynamicValue(RS_19_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_19_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
+ predicate:((ss_hdemo_sk BETWEEN DynamicValue(RS_13_household_demographics_hd_demo_sk_min) AND DynamicValue(RS_13_household_demographics_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_13_household_demographics_hd_demo_sk_bloom_filter))) and (ss_sold_time_sk BETWEEN DynamicValue(RS_16_time_dim_t_time_sk_min) AND DynamicValue(RS_16_time_dim_t_time_sk_max) and in_bloom_filter(ss_sold_time_sk, DynamicValue(RS_16_time_dim_t_time_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_19_store_s_store_sk_min) AND DynamicValue(RS_19_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_19_store_s_store_sk_bloom_filter))) and ss_hdemo_sk is not null and ss_sold_time_sk is not null and ss_store_sk is not null)
TableScan [TS_0] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_time_sk","ss_hdemo_sk","ss_store_sk"]
<-Reducer 45 [BROADCAST_EDGE] vectorized
@@ -882,9 +882,9 @@ Stage-0
PARTITION_ONLY_SHUFFLE [RS_664]
Group By Operator [GBY_656] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_641] (rows=3600 width=107)
+ Select Operator [SEL_641] (rows=14400 width=471)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_639]
+ Please refer to the previous Select Operator [SEL_632]
<-Reducer 54 [BROADCAST_EDGE] vectorized
BROADCAST [RS_709]
Group By Operator [GBY_708] (rows=1 width=12)
@@ -897,14 +897,14 @@ Stage-0
Output:["_col0"]
Please refer to the previous Select Operator [SEL_675]
<-Reducer 8 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_637]
- Group By Operator [GBY_636] (rows=1 width=12)
+ BROADCAST [RS_623]
+ Group By Operator [GBY_622] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 7 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_628]
- Group By Operator [GBY_620] (rows=1 width=12)
+ SHUFFLE [RS_614]
+ Group By Operator [GBY_606] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_605] (rows=14400 width=471)
+ Select Operator [SEL_591] (rows=2000 width=107)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_596]
+ Please refer to the previous Select Operator [SEL_589]