You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/07/18 18:52:05 UTC
[09/48] hive git commit: HIVE-20090 : Extend creation of semijoin
reduction filters to be able to discover new opportunities (Jesus Camacho
Rodriguez via Deepak Jaiswal)
http://git-wip-us.apache.org/repos/asf/hive/blob/ab9e954d/ql/src/test/results/clientpositive/perf/tez/query64.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/tez/query64.q.out b/ql/src/test/results/clientpositive/perf/tez/query64.q.out
index a673b9f..6d3edd3 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query64.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query64.q.out
@@ -237,31 +237,32 @@ POSTHOOK: type: QUERY
Plan optimized by CBO.
Vertex dependency in root stage
-Map 40 <- Reducer 23 (BROADCAST_EDGE), Reducer 34 (BROADCAST_EDGE), Reducer 38 (BROADCAST_EDGE), Reducer 43 (BROADCAST_EDGE), Reducer 47 (BROADCAST_EDGE), Reducer 52 (BROADCAST_EDGE), Reducer 58 (BROADCAST_EDGE), Reducer 61 (BROADCAST_EDGE), Reducer 62 (BROADCAST_EDGE), Reducer 66 (BROADCAST_EDGE)
-Map 49 <- Reducer 55 (BROADCAST_EDGE), Reducer 56 (BROADCAST_EDGE), Reducer 61 (BROADCAST_EDGE)
-Map 68 <- Reducer 31 (BROADCAST_EDGE), Reducer 35 (BROADCAST_EDGE), Reducer 39 (BROADCAST_EDGE), Reducer 45 (BROADCAST_EDGE), Reducer 48 (BROADCAST_EDGE), Reducer 53 (BROADCAST_EDGE), Reducer 59 (BROADCAST_EDGE), Reducer 63 (BROADCAST_EDGE), Reducer 64 (BROADCAST_EDGE), Reducer 67 (BROADCAST_EDGE)
+Map 40 <- Reducer 23 (BROADCAST_EDGE), Reducer 34 (BROADCAST_EDGE), Reducer 38 (BROADCAST_EDGE), Reducer 43 (BROADCAST_EDGE), Reducer 47 (BROADCAST_EDGE), Reducer 52 (BROADCAST_EDGE), Reducer 62 (BROADCAST_EDGE), Reducer 65 (BROADCAST_EDGE), Reducer 66 (BROADCAST_EDGE), Reducer 70 (BROADCAST_EDGE)
+Map 49 <- Reducer 43 (BROADCAST_EDGE), Reducer 54 (BROADCAST_EDGE), Reducer 55 (BROADCAST_EDGE), Reducer 65 (BROADCAST_EDGE)
+Map 72 <- Reducer 31 (BROADCAST_EDGE), Reducer 35 (BROADCAST_EDGE), Reducer 39 (BROADCAST_EDGE), Reducer 43 (BROADCAST_EDGE), Reducer 45 (BROADCAST_EDGE), Reducer 48 (BROADCAST_EDGE), Reducer 58 (BROADCAST_EDGE), Reducer 63 (BROADCAST_EDGE), Reducer 67 (BROADCAST_EDGE), Reducer 68 (BROADCAST_EDGE), Reducer 71 (BROADCAST_EDGE)
+Map 73 <- Reducer 45 (BROADCAST_EDGE), Reducer 59 (BROADCAST_EDGE), Reducer 60 (BROADCAST_EDGE), Reducer 67 (BROADCAST_EDGE)
Reducer 10 <- Reducer 14 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE)
Reducer 11 <- Reducer 10 (SIMPLE_EDGE)
Reducer 12 <- Reducer 30 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE)
-Reducer 13 <- Map 65 (SIMPLE_EDGE), Reducer 12 (SIMPLE_EDGE)
+Reducer 13 <- Map 69 (SIMPLE_EDGE), Reducer 12 (SIMPLE_EDGE)
Reducer 14 <- Reducer 13 (SIMPLE_EDGE)
Reducer 16 <- Map 15 (SIMPLE_EDGE), Reducer 41 (SIMPLE_EDGE)
Reducer 17 <- Map 46 (SIMPLE_EDGE), Reducer 16 (SIMPLE_EDGE)
Reducer 18 <- Reducer 17 (SIMPLE_EDGE), Reducer 33 (SIMPLE_EDGE)
Reducer 19 <- Reducer 18 (SIMPLE_EDGE), Reducer 51 (ONE_TO_ONE_EDGE)
Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 15 (SIMPLE_EDGE)
-Reducer 20 <- Map 57 (SIMPLE_EDGE), Reducer 19 (SIMPLE_EDGE)
+Reducer 20 <- Map 61 (SIMPLE_EDGE), Reducer 19 (SIMPLE_EDGE)
Reducer 21 <- Map 37 (SIMPLE_EDGE), Reducer 20 (SIMPLE_EDGE)
-Reducer 22 <- Map 60 (SIMPLE_EDGE), Reducer 21 (SIMPLE_EDGE)
+Reducer 22 <- Map 64 (SIMPLE_EDGE), Reducer 21 (SIMPLE_EDGE)
Reducer 23 <- Map 15 (CUSTOM_SIMPLE_EDGE)
Reducer 24 <- Map 15 (SIMPLE_EDGE), Reducer 44 (SIMPLE_EDGE)
Reducer 25 <- Map 46 (SIMPLE_EDGE), Reducer 24 (SIMPLE_EDGE)
Reducer 26 <- Reducer 25 (SIMPLE_EDGE), Reducer 33 (SIMPLE_EDGE)
-Reducer 27 <- Reducer 26 (SIMPLE_EDGE), Reducer 51 (ONE_TO_ONE_EDGE)
-Reducer 28 <- Map 57 (SIMPLE_EDGE), Reducer 27 (SIMPLE_EDGE)
+Reducer 27 <- Reducer 26 (SIMPLE_EDGE), Reducer 57 (ONE_TO_ONE_EDGE)
+Reducer 28 <- Map 61 (SIMPLE_EDGE), Reducer 27 (SIMPLE_EDGE)
Reducer 29 <- Map 37 (SIMPLE_EDGE), Reducer 28 (SIMPLE_EDGE)
Reducer 3 <- Map 15 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE)
-Reducer 30 <- Map 60 (SIMPLE_EDGE), Reducer 29 (SIMPLE_EDGE)
+Reducer 30 <- Map 64 (SIMPLE_EDGE), Reducer 29 (SIMPLE_EDGE)
Reducer 31 <- Map 15 (CUSTOM_SIMPLE_EDGE)
Reducer 33 <- Map 32 (SIMPLE_EDGE), Map 36 (SIMPLE_EDGE)
Reducer 34 <- Reducer 33 (CUSTOM_SIMPLE_EDGE)
@@ -271,28 +272,32 @@ Reducer 39 <- Map 37 (CUSTOM_SIMPLE_EDGE)
Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 33 (SIMPLE_EDGE)
Reducer 41 <- Map 40 (SIMPLE_EDGE), Map 42 (SIMPLE_EDGE)
Reducer 43 <- Map 42 (CUSTOM_SIMPLE_EDGE)
-Reducer 44 <- Map 42 (SIMPLE_EDGE), Map 68 (SIMPLE_EDGE)
+Reducer 44 <- Map 42 (SIMPLE_EDGE), Map 72 (SIMPLE_EDGE)
Reducer 45 <- Map 42 (CUSTOM_SIMPLE_EDGE)
Reducer 47 <- Map 46 (CUSTOM_SIMPLE_EDGE)
Reducer 48 <- Map 46 (CUSTOM_SIMPLE_EDGE)
Reducer 5 <- Map 37 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE)
-Reducer 50 <- Map 49 (SIMPLE_EDGE), Map 54 (SIMPLE_EDGE)
+Reducer 50 <- Map 49 (SIMPLE_EDGE), Map 53 (SIMPLE_EDGE)
Reducer 51 <- Reducer 50 (SIMPLE_EDGE)
Reducer 52 <- Reducer 51 (CUSTOM_SIMPLE_EDGE)
-Reducer 53 <- Reducer 51 (CUSTOM_SIMPLE_EDGE)
-Reducer 55 <- Map 54 (CUSTOM_SIMPLE_EDGE)
-Reducer 56 <- Map 54 (CUSTOM_SIMPLE_EDGE)
-Reducer 58 <- Map 57 (CUSTOM_SIMPLE_EDGE)
-Reducer 59 <- Map 57 (CUSTOM_SIMPLE_EDGE)
-Reducer 6 <- Map 65 (SIMPLE_EDGE), Reducer 5 (SIMPLE_EDGE)
-Reducer 61 <- Map 60 (CUSTOM_SIMPLE_EDGE)
-Reducer 62 <- Map 60 (CUSTOM_SIMPLE_EDGE)
-Reducer 63 <- Map 60 (CUSTOM_SIMPLE_EDGE)
-Reducer 64 <- Map 60 (CUSTOM_SIMPLE_EDGE)
-Reducer 66 <- Map 65 (CUSTOM_SIMPLE_EDGE)
-Reducer 67 <- Map 65 (CUSTOM_SIMPLE_EDGE)
+Reducer 54 <- Map 53 (CUSTOM_SIMPLE_EDGE)
+Reducer 55 <- Map 53 (CUSTOM_SIMPLE_EDGE)
+Reducer 56 <- Map 53 (SIMPLE_EDGE), Map 73 (SIMPLE_EDGE)
+Reducer 57 <- Reducer 56 (SIMPLE_EDGE)
+Reducer 58 <- Reducer 57 (CUSTOM_SIMPLE_EDGE)
+Reducer 59 <- Map 53 (CUSTOM_SIMPLE_EDGE)
+Reducer 6 <- Map 69 (SIMPLE_EDGE), Reducer 5 (SIMPLE_EDGE)
+Reducer 60 <- Map 53 (CUSTOM_SIMPLE_EDGE)
+Reducer 62 <- Map 61 (CUSTOM_SIMPLE_EDGE)
+Reducer 63 <- Map 61 (CUSTOM_SIMPLE_EDGE)
+Reducer 65 <- Map 64 (CUSTOM_SIMPLE_EDGE)
+Reducer 66 <- Map 64 (CUSTOM_SIMPLE_EDGE)
+Reducer 67 <- Map 64 (CUSTOM_SIMPLE_EDGE)
+Reducer 68 <- Map 64 (CUSTOM_SIMPLE_EDGE)
Reducer 7 <- Reducer 22 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE)
-Reducer 8 <- Map 65 (SIMPLE_EDGE), Reducer 7 (SIMPLE_EDGE)
+Reducer 70 <- Map 69 (CUSTOM_SIMPLE_EDGE)
+Reducer 71 <- Map 69 (CUSTOM_SIMPLE_EDGE)
+Reducer 8 <- Map 69 (SIMPLE_EDGE), Reducer 7 (SIMPLE_EDGE)
Reducer 9 <- Reducer 8 (SIMPLE_EDGE)
Stage-0
@@ -300,8 +305,8 @@ Stage-0
limit:-1
Stage-1
Reducer 11 vectorized
- File Output Operator [FS_1230]
- Select Operator [SEL_1229] (rows=273897192 width=88)
+ File Output Operator [FS_1283]
+ Select Operator [SEL_1282] (rows=273897192 width=88)
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15","_col16","_col17","_col18","_col19","_col20"]
<-Reducer 10 [SIMPLE_EDGE]
SHUFFLE [RS_259]
@@ -309,14 +314,14 @@ Stage-0
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15","_col16","_col17","_col18"]
Filter Operator [FIL_257] (rows=273897192 width=88)
predicate:(_col19 <= _col12)
- Merge Join Operator [MERGEJOIN_1055] (rows=821691577 width=88)
- Conds:RS_1202._col2, _col1, _col3=RS_1228._col1, _col0, _col2(Inner),Output:["_col0","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15","_col19","_col20","_col21","_col22"]
+ Merge Join Operator [MERGEJOIN_1087] (rows=821691577 width=88)
+ Conds:RS_1239._col2, _col1, _col3=RS_1281._col1, _col0, _col2(Inner),Output:["_col0","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15","_col19","_col20","_col21","_col22"]
<-Reducer 14 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1228]
+ SHUFFLE [RS_1281]
PartitionCols:_col1, _col0, _col2
- Select Operator [SEL_1227] (rows=746992327 width=88)
+ Select Operator [SEL_1280] (rows=746992327 width=88)
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"]
- Group By Operator [GBY_1226] (rows=746992327 width=88)
+ Group By Operator [GBY_1279] (rows=746992327 width=88)
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15","_col16","_col17"],aggregations:["count(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4, KEY._col5, KEY._col6, KEY._col7, KEY._col8, KEY._col9, KEY._col10, KEY._col11, KEY._col12, KEY._col13
<-Reducer 13 [SIMPLE_EDGE]
SHUFFLE [RS_251]
@@ -327,102 +332,102 @@ Stage-0
Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col49"]
Filter Operator [FIL_248] (rows=1493984654 width=88)
predicate:(_col56 <> _col19)
- Merge Join Operator [MERGEJOIN_1054] (rows=1493984654 width=88)
- Conds:RS_245._col37=RS_1097._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col49","_col56"]
- <-Map 65 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1097]
+ Merge Join Operator [MERGEJOIN_1086] (rows=1493984654 width=88)
+ Conds:RS_245._col37=RS_1129._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col49","_col56"]
+ <-Map 69 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_1129]
PartitionCols:_col0
- Select Operator [SEL_1093] (rows=1861800 width=385)
+ Select Operator [SEL_1125] (rows=1861800 width=385)
Output:["_col0","_col1"]
- Filter Operator [FIL_1092] (rows=1861800 width=385)
+ Filter Operator [FIL_1124] (rows=1861800 width=385)
predicate:cd_demo_sk is not null
TableScan [TS_97] (rows=1861800 width=385)
default@customer_demographics,cd1,Tbl:COMPLETE,Col:NONE,Output:["cd_demo_sk","cd_marital_status"]
<-Reducer 12 [SIMPLE_EDGE]
SHUFFLE [RS_245]
PartitionCols:_col37
- Merge Join Operator [MERGEJOIN_1053] (rows=1358167838 width=88)
+ Merge Join Operator [MERGEJOIN_1085] (rows=1358167838 width=88)
Conds:RS_242._col0=RS_243._col16(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col37","_col43","_col44","_col45","_col46","_col49"]
<-Reducer 6 [SIMPLE_EDGE]
SHUFFLE [RS_242]
PartitionCols:_col0
- Merge Join Operator [MERGEJOIN_1024] (rows=128840811 width=860)
- Conds:RS_112._col1=RS_1096._col0(Inner),Output:["_col0","_col7","_col9","_col14","_col15","_col16","_col17","_col19"]
- <-Map 65 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1096]
+ Merge Join Operator [MERGEJOIN_1056] (rows=128840811 width=860)
+ Conds:RS_112._col1=RS_1128._col0(Inner),Output:["_col0","_col7","_col9","_col14","_col15","_col16","_col17","_col19"]
+ <-Map 69 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_1128]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_1093]
+ Please refer to the previous Select Operator [SEL_1125]
<-Reducer 5 [SIMPLE_EDGE]
SHUFFLE [RS_112]
PartitionCols:_col1
- Merge Join Operator [MERGEJOIN_1023] (rows=117128008 width=860)
- Conds:RS_109._col3=RS_1083._col0(Inner),Output:["_col0","_col1","_col7","_col9","_col14","_col15","_col16","_col17"]
+ Merge Join Operator [MERGEJOIN_1055] (rows=117128008 width=860)
+ Conds:RS_109._col3=RS_1115._col0(Inner),Output:["_col0","_col1","_col7","_col9","_col14","_col15","_col16","_col17"]
<-Map 37 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1083]
+ SHUFFLE [RS_1115]
PartitionCols:_col0
- Select Operator [SEL_1082] (rows=40000000 width=1014)
+ Select Operator [SEL_1114] (rows=40000000 width=1014)
Output:["_col0","_col1","_col2","_col3","_col4"]
- Filter Operator [FIL_1081] (rows=40000000 width=1014)
+ Filter Operator [FIL_1113] (rows=40000000 width=1014)
predicate:ca_address_sk is not null
TableScan [TS_19] (rows=40000000 width=1014)
default@customer_address,ad2,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_street_number","ca_street_name","ca_city","ca_zip"]
<-Reducer 4 [SIMPLE_EDGE]
SHUFFLE [RS_109]
PartitionCols:_col3
- Merge Join Operator [MERGEJOIN_1022] (rows=106480005 width=860)
+ Merge Join Operator [MERGEJOIN_1054] (rows=106480005 width=860)
Conds:RS_106._col2=RS_107._col0(Inner),Output:["_col0","_col1","_col3","_col7","_col9"]
<-Reducer 33 [SIMPLE_EDGE]
SHUFFLE [RS_107]
PartitionCols:_col0
- Merge Join Operator [MERGEJOIN_1021] (rows=7920 width=107)
- Conds:RS_1077._col1=RS_1080._col0(Inner),Output:["_col0"]
+ Merge Join Operator [MERGEJOIN_1053] (rows=7920 width=107)
+ Conds:RS_1109._col1=RS_1112._col0(Inner),Output:["_col0"]
<-Map 32 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1077]
+ SHUFFLE [RS_1109]
PartitionCols:_col1
- Select Operator [SEL_1076] (rows=7200 width=107)
+ Select Operator [SEL_1108] (rows=7200 width=107)
Output:["_col0","_col1"]
- Filter Operator [FIL_1075] (rows=7200 width=107)
+ Filter Operator [FIL_1107] (rows=7200 width=107)
predicate:(hd_demo_sk is not null and hd_income_band_sk is not null)
TableScan [TS_9] (rows=7200 width=107)
default@household_demographics,hd2,Tbl:COMPLETE,Col:NONE,Output:["hd_demo_sk","hd_income_band_sk"]
<-Map 36 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1080]
+ SHUFFLE [RS_1112]
PartitionCols:_col0
- Select Operator [SEL_1079] (rows=20 width=12)
+ Select Operator [SEL_1111] (rows=20 width=12)
Output:["_col0"]
- Filter Operator [FIL_1078] (rows=20 width=12)
+ Filter Operator [FIL_1110] (rows=20 width=12)
predicate:ib_income_band_sk is not null
TableScan [TS_12] (rows=20 width=12)
default@income_band,ib2,Tbl:COMPLETE,Col:NONE,Output:["ib_income_band_sk"]
<-Reducer 3 [SIMPLE_EDGE]
SHUFFLE [RS_106]
PartitionCols:_col2
- Merge Join Operator [MERGEJOIN_1020] (rows=96800003 width=860)
- Conds:RS_103._col4=RS_1066._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col7","_col9"]
+ Merge Join Operator [MERGEJOIN_1052] (rows=96800003 width=860)
+ Conds:RS_103._col4=RS_1098._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col7","_col9"]
<-Map 15 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1066]
+ PARTITION_ONLY_SHUFFLE [RS_1098]
PartitionCols:_col0
- Select Operator [SEL_1062] (rows=73049 width=1119)
+ Select Operator [SEL_1094] (rows=73049 width=1119)
Output:["_col0","_col1"]
- Filter Operator [FIL_1059] (rows=73049 width=1119)
+ Filter Operator [FIL_1091] (rows=73049 width=1119)
predicate:d_date_sk is not null
TableScan [TS_3] (rows=73049 width=1119)
default@date_dim,d2,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"]
<-Reducer 2 [SIMPLE_EDGE]
SHUFFLE [RS_103]
PartitionCols:_col4
- Merge Join Operator [MERGEJOIN_1019] (rows=88000001 width=860)
- Conds:RS_1058._col5=RS_1065._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col7"]
+ Merge Join Operator [MERGEJOIN_1051] (rows=88000001 width=860)
+ Conds:RS_1090._col5=RS_1097._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col7"]
<-Map 15 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1065]
+ PARTITION_ONLY_SHUFFLE [RS_1097]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_1062]
+ Please refer to the previous Select Operator [SEL_1094]
<-Map 1 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1058]
+ SHUFFLE [RS_1090]
PartitionCols:_col5
- Select Operator [SEL_1057] (rows=80000000 width=860)
+ Select Operator [SEL_1089] (rows=80000000 width=860)
Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
- Filter Operator [FIL_1056] (rows=80000000 width=860)
+ Filter Operator [FIL_1088] (rows=80000000 width=860)
predicate:(c_current_addr_sk is not null and c_current_cdemo_sk is not null and c_current_hdemo_sk is not null and c_customer_sk is not null and c_first_sales_date_sk is not null and c_first_shipto_date_sk is not null)
TableScan [TS_0] (rows=80000000 width=860)
default@customer,customer,Tbl:COMPLETE,Col:NONE,Output:["c_customer_sk","c_current_cdemo_sk","c_current_hdemo_sk","c_current_addr_sk","c_first_shipto_date_sk","c_first_sales_date_sk"]
@@ -431,291 +436,297 @@ Stage-0
PartitionCols:_col16
Select Operator [SEL_223] (rows=1234698008 width=88)
Output:["_col3","_col4","_col5","_col6","_col8","_col9","_col16","_col17","_col23","_col24","_col25","_col26","_col29"]
- Merge Join Operator [MERGEJOIN_1052] (rows=1234698008 width=88)
- Conds:RS_220._col5, _col12=RS_1149._col0, _col1(Inner),Output:["_col6","_col7","_col13","_col14","_col15","_col16","_col19","_col26","_col27","_col29","_col30","_col31","_col32"]
- <-Map 60 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1149]
+ Merge Join Operator [MERGEJOIN_1084] (rows=1234698008 width=88)
+ Conds:RS_220._col5, _col12=RS_1190._col0, _col1(Inner),Output:["_col6","_col7","_col13","_col14","_col15","_col16","_col19","_col26","_col27","_col29","_col30","_col31","_col32"]
+ <-Map 64 [SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1190]
PartitionCols:_col0, _col1
- Select Operator [SEL_1145] (rows=57591150 width=77)
+ Select Operator [SEL_1186] (rows=57591150 width=77)
Output:["_col0","_col1"]
- Filter Operator [FIL_1144] (rows=57591150 width=77)
+ Filter Operator [FIL_1185] (rows=57591150 width=77)
predicate:(sr_item_sk is not null and sr_ticket_number is not null)
TableScan [TS_75] (rows=57591150 width=77)
default@store_returns,store_returns,Tbl:COMPLETE,Col:NONE,Output:["sr_item_sk","sr_ticket_number"]
<-Reducer 29 [SIMPLE_EDGE]
SHUFFLE [RS_220]
PartitionCols:_col5, _col12
- Merge Join Operator [MERGEJOIN_1051] (rows=1122452711 width=88)
- Conds:RS_217._col9=RS_1086._col0(Inner),Output:["_col5","_col6","_col7","_col12","_col13","_col14","_col15","_col16","_col19","_col26","_col27","_col29","_col30","_col31","_col32"]
+ Merge Join Operator [MERGEJOIN_1083] (rows=1122452711 width=88)
+ Conds:RS_217._col9=RS_1118._col0(Inner),Output:["_col5","_col6","_col7","_col12","_col13","_col14","_col15","_col16","_col19","_col26","_col27","_col29","_col30","_col31","_col32"]
<-Map 37 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1086]
+ SHUFFLE [RS_1118]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_1082]
+ Please refer to the previous Select Operator [SEL_1114]
<-Reducer 28 [SIMPLE_EDGE]
SHUFFLE [RS_217]
PartitionCols:_col9
- Merge Join Operator [MERGEJOIN_1050] (rows=1020411534 width=88)
- Conds:RS_214._col10=RS_1183._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col12","_col13","_col14","_col15","_col16","_col19","_col26","_col27"]
- <-Map 57 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1183]
+ Merge Join Operator [MERGEJOIN_1082] (rows=1020411534 width=88)
+ Conds:RS_214._col10=RS_1220._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col12","_col13","_col14","_col15","_col16","_col19","_col26","_col27"]
+ <-Map 61 [SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1220]
PartitionCols:_col0
- Select Operator [SEL_1180] (rows=1704 width=1910)
+ Select Operator [SEL_1217] (rows=1704 width=1910)
Output:["_col0","_col1","_col2"]
- Filter Operator [FIL_1179] (rows=1704 width=1910)
+ Filter Operator [FIL_1216] (rows=1704 width=1910)
predicate:(s_store_name is not null and s_store_sk is not null and s_zip is not null)
TableScan [TS_69] (rows=1704 width=1910)
default@store,store,Tbl:COMPLETE,Col:NONE,Output:["s_store_sk","s_store_name","s_zip"]
<-Reducer 27 [SIMPLE_EDGE]
SHUFFLE [RS_214]
PartitionCols:_col10
- Merge Join Operator [MERGEJOIN_1049] (rows=927646829 width=88)
- Conds:RS_211._col5=RS_1171._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col19"]
- <-Reducer 51 [ONE_TO_ONE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1171]
+ Merge Join Operator [MERGEJOIN_1081] (rows=927646829 width=88)
+ Conds:RS_211._col5=RS_1262._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col19"]
+ <-Reducer 57 [ONE_TO_ONE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1262]
PartitionCols:_col0
- Select Operator [SEL_1168] (rows=52798137 width=135)
+ Select Operator [SEL_1261] (rows=52798137 width=135)
Output:["_col0"]
- Filter Operator [FIL_1167] (rows=52798137 width=135)
+ Filter Operator [FIL_1260] (rows=52798137 width=135)
predicate:(_col1 > (2 * _col2))
- Group By Operator [GBY_1166] (rows=158394413 width=135)
+ Group By Operator [GBY_1259] (rows=158394413 width=135)
Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0
- <-Reducer 50 [SIMPLE_EDGE]
- SHUFFLE [RS_65]
+ <-Reducer 56 [SIMPLE_EDGE]
+ SHUFFLE [RS_192]
PartitionCols:_col0
- Group By Operator [GBY_64] (rows=316788826 width=135)
+ Group By Operator [GBY_191] (rows=316788826 width=135)
Output:["_col0","_col1","_col2"],aggregations:["sum(_col1)","sum(_col2)"],keys:_col0
- Select Operator [SEL_62] (rows=316788826 width=135)
+ Select Operator [SEL_189] (rows=316788826 width=135)
Output:["_col0","_col1","_col2"]
- Merge Join Operator [MERGEJOIN_1029] (rows=316788826 width=135)
- Conds:RS_1165._col0, _col1=RS_1133._col0, _col1(Inner),Output:["_col0","_col2","_col5","_col6","_col7"]
- <-Map 54 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1133]
+ Merge Join Operator [MERGEJOIN_1079] (rows=316788826 width=135)
+ Conds:RS_1258._col0, _col1=RS_1170._col0, _col1(Inner),Output:["_col0","_col2","_col5","_col6","_col7"]
+ <-Map 53 [SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1170]
PartitionCols:_col0, _col1
- Select Operator [SEL_1132] (rows=28798881 width=106)
+ Select Operator [SEL_1166] (rows=28798881 width=106)
Output:["_col0","_col1","_col2","_col3","_col4"]
- Filter Operator [FIL_1131] (rows=28798881 width=106)
+ Filter Operator [FIL_1165] (rows=28798881 width=106)
predicate:(cr_item_sk is not null and cr_order_number is not null)
TableScan [TS_56] (rows=28798881 width=106)
default@catalog_returns,catalog_returns,Tbl:COMPLETE,Col:NONE,Output:["cr_item_sk","cr_order_number","cr_refunded_cash","cr_reversed_charge","cr_store_credit"]
- <-Map 49 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1165]
+ <-Map 73 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_1258]
PartitionCols:_col0, _col1
- Select Operator [SEL_1164] (rows=287989836 width=135)
+ Select Operator [SEL_1257] (rows=287989836 width=135)
Output:["_col0","_col1","_col2"]
- Filter Operator [FIL_1163] (rows=287989836 width=135)
- predicate:((cs_item_sk BETWEEN DynamicValue(RS_60_catalog_returns_cr_item_sk_min) AND DynamicValue(RS_60_catalog_returns_cr_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_60_catalog_returns_cr_item_sk_bloom_filter))) and (cs_item_sk BETWEEN DynamicValue(RS_94_store_returns_sr_item_sk_min) AND DynamicValue(RS_94_store_returns_sr_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_94_store_returns_sr_item_sk_bloom_filter))) and (cs_order_number BETWEEN DynamicValue(RS_60_catalog_returns_cr_order_number_min) AND DynamicValue(RS_60_catalog_returns_cr_order_number_max) and in_bloom_filter(cs_order_number, DynamicValue(RS_60_catalog_returns_cr_order_number_bloom_filter))) and cs_item_sk is not null and cs_order_number is not null)
- TableScan [TS_53] (rows=287989836 width=135)
+ Filter Operator [FIL_1256] (rows=287989836 width=135)
+ predicate:((cs_item_sk BETWEEN DynamicValue(RS_171_item_i_item_sk_min) AND DynamicValue(RS_171_item_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_171_item_i_item_sk_bloom_filter))) and (cs_item_sk BETWEEN DynamicValue(RS_187_catalog_returns_cr_item_sk_min) AND DynamicValue(RS_187_catalog_returns_cr_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_187_catalog_returns_cr_item_sk_bloom_filter))) and (cs_item_sk BETWEEN DynamicValue(RS_221_store_returns_sr_item_sk_min) AND DynamicValue(RS_221_store_returns_sr_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_221_store_returns_sr_item_sk_bloom_filter))) and (cs_order_number BETWEEN DynamicValue(RS_187_catalog_returns_cr_order_number_min) AND DynamicValue(RS_187_catalog_returns_cr_order_number_max) and in_bloom_filter(cs_order_number, DynamicValue(RS_187_catalog_returns_cr_order_number_bloom_filter))) and cs_item_sk is not
null and cs_order_number is not null)
+ TableScan [TS_180] (rows=287989836 width=135)
default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:NONE,Output:["cs_item_sk","cs_order_number","cs_ext_list_price"]
- <-Reducer 61 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1162]
- Group By Operator [GBY_1160] (rows=1 width=12)
+ <-Reducer 45 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1242]
+ Group By Operator [GBY_1240] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
+ <-Map 42 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1144]
+ Group By Operator [GBY_1142] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
+ Select Operator [SEL_1140] (rows=2851 width=1436)
+ Output:["_col0"]
+ Select Operator [SEL_1136] (rows=2851 width=1436)
+ Output:["_col0","_col3"]
+ Filter Operator [FIL_1135] (rows=2851 width=1436)
+ predicate:((i_color) IN ('maroon', 'burnished', 'dim', 'steel', 'navajo', 'chocolate') and i_current_price BETWEEN 35 AND 45 and i_current_price BETWEEN 36 AND 50 and i_item_sk is not null)
+ TableScan [TS_34] (rows=462000 width=1436)
+ default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_current_price","i_color","i_product_name"]
+ <-Reducer 67 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1255]
+ Group By Operator [GBY_1253] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=57591152)"]
- <-Map 60 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1156]
- Group By Operator [GBY_1152] (rows=1 width=12)
+ <-Map 64 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1199]
+ Group By Operator [GBY_1195] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=57591152)"]
- Select Operator [SEL_1147] (rows=57591150 width=77)
+ Select Operator [SEL_1191] (rows=57591150 width=77)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1145]
- <-Reducer 55 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1141]
- Group By Operator [GBY_1140] (rows=1 width=12)
+ Please refer to the previous Select Operator [SEL_1186]
+ <-Reducer 59 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1250]
+ Group By Operator [GBY_1249] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=28798880)"]
- <-Map 54 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1138]
- Group By Operator [GBY_1136] (rows=1 width=12)
+ <-Map 53 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1179]
+ Group By Operator [GBY_1175] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=28798880)"]
- Select Operator [SEL_1134] (rows=28798881 width=106)
+ Select Operator [SEL_1171] (rows=28798881 width=106)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1132]
- <-Reducer 56 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1143]
- Group By Operator [GBY_1142] (rows=1 width=12)
+ Please refer to the previous Select Operator [SEL_1166]
+ <-Reducer 60 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1252]
+ Group By Operator [GBY_1251] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=28798880)"]
- <-Map 54 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1139]
- Group By Operator [GBY_1137] (rows=1 width=12)
+ <-Map 53 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1180]
+ Group By Operator [GBY_1176] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=28798880)"]
- Select Operator [SEL_1135] (rows=28798881 width=106)
+ Select Operator [SEL_1172] (rows=28798881 width=106)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1132]
+ Please refer to the previous Select Operator [SEL_1166]
<-Reducer 26 [SIMPLE_EDGE]
SHUFFLE [RS_211]
PartitionCols:_col5
- Merge Join Operator [MERGEJOIN_1048] (rows=843315281 width=88)
+ Merge Join Operator [MERGEJOIN_1080] (rows=843315281 width=88)
Conds:RS_208._col0=RS_209._col5(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col19"]
<-Reducer 33 [SIMPLE_EDGE]
SHUFFLE [RS_208]
PartitionCols:_col0
- Please refer to the previous Merge Join Operator [MERGEJOIN_1021]
+ Please refer to the previous Merge Join Operator [MERGEJOIN_1053]
<-Reducer 25 [SIMPLE_EDGE]
SHUFFLE [RS_209]
PartitionCols:_col5
Select Operator [SEL_179] (rows=766650239 width=88)
Output:["_col2","_col3","_col4","_col5","_col6","_col7","_col9","_col10","_col11","_col12","_col13","_col16"]
- Merge Join Operator [MERGEJOIN_1046] (rows=766650239 width=88)
- Conds:RS_176._col7=RS_1121._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col8","_col9","_col10","_col11","_col12","_col15"]
+ Merge Join Operator [MERGEJOIN_1078] (rows=766650239 width=88)
+ Conds:RS_176._col7=RS_1155._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col8","_col9","_col10","_col11","_col12","_col15"]
<-Map 46 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1121]
+ PARTITION_ONLY_SHUFFLE [RS_1155]
PartitionCols:_col0
- Select Operator [SEL_1118] (rows=2300 width=1179)
+ Select Operator [SEL_1152] (rows=2300 width=1179)
Output:["_col0"]
- Filter Operator [FIL_1117] (rows=2300 width=1179)
+ Filter Operator [FIL_1151] (rows=2300 width=1179)
predicate:p_promo_sk is not null
TableScan [TS_40] (rows=2300 width=1179)
default@promotion,promotion,Tbl:COMPLETE,Col:NONE,Output:["p_promo_sk"]
<-Reducer 24 [SIMPLE_EDGE]
SHUFFLE [RS_176]
PartitionCols:_col7
- Merge Join Operator [MERGEJOIN_1045] (rows=696954748 width=88)
- Conds:RS_173._col0=RS_1069._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col15"]
+ Merge Join Operator [MERGEJOIN_1077] (rows=696954748 width=88)
+ Conds:RS_173._col0=RS_1101._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col15"]
<-Map 15 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1069]
+ PARTITION_ONLY_SHUFFLE [RS_1101]
PartitionCols:_col0
- Select Operator [SEL_1064] (rows=36524 width=1119)
+ Select Operator [SEL_1096] (rows=36524 width=1119)
Output:["_col0"]
- Filter Operator [FIL_1061] (rows=36524 width=1119)
+ Filter Operator [FIL_1093] (rows=36524 width=1119)
predicate:((d_year = 2001) and d_date_sk is not null)
Please refer to the previous TableScan [TS_3]
<-Reducer 44 [SIMPLE_EDGE]
SHUFFLE [RS_173]
PartitionCols:_col0
- Merge Join Operator [MERGEJOIN_1044] (rows=633595212 width=88)
- Conds:RS_1225._col1=RS_1107._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col15"]
+ Merge Join Operator [MERGEJOIN_1076] (rows=633595212 width=88)
+ Conds:RS_1278._col1=RS_1139._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col15"]
<-Map 42 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1107]
+ PARTITION_ONLY_SHUFFLE [RS_1139]
PartitionCols:_col0
- Select Operator [SEL_1104] (rows=2851 width=1436)
- Output:["_col0","_col3"]
- Filter Operator [FIL_1103] (rows=2851 width=1436)
- predicate:((i_color) IN ('maroon', 'burnished', 'dim', 'steel', 'navajo', 'chocolate') and i_current_price BETWEEN 35 AND 45 and i_current_price BETWEEN 36 AND 50 and i_item_sk is not null)
- TableScan [TS_34] (rows=462000 width=1436)
- default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_current_price","i_color","i_product_name"]
- <-Map 68 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1225]
+ Please refer to the previous Select Operator [SEL_1136]
+ <-Map 72 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_1278]
PartitionCols:_col1
- Select Operator [SEL_1224] (rows=575995635 width=88)
+ Select Operator [SEL_1277] (rows=575995635 width=88)
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11"]
- Filter Operator [FIL_1223] (rows=575995635 width=88)
- predicate:((ss_addr_sk BETWEEN DynamicValue(RS_218_ad1_ca_address_sk_min) AND DynamicValue(RS_218_ad1_ca_address_sk_max) and in_bloom_filter(ss_addr_sk, DynamicValue(RS_218_ad1_ca_address_sk_bloom_filter))) and (ss_cdemo_sk BETWEEN DynamicValue(RS_246_cd1_cd_demo_sk_min) AND DynamicValue(RS_246_cd1_cd_demo_sk_max) and in_bloom_filter(ss_cdemo_sk, DynamicValue(RS_246_cd1_cd_demo_sk_bloom_filter))) and (ss_hdemo_sk BETWEEN DynamicValue(RS_208_hd1_hd_demo_sk_min) AND DynamicValue(RS_208_hd1_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_208_hd1_hd_demo_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_171_item_i_item_sk_min) AND DynamicValue(RS_171_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_171_item_i_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_212_catalog_sales_cs_item_sk_min) AND DynamicValue(RS_212_catalog_sales_cs_item_sk_max) and i
n_bloom_filter(ss_item_sk, DynamicValue(RS_212_catalog_sales_cs_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_221_store_returns_sr_item_sk_min) AND DynamicValue(RS_221_store_returns_sr_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_221_store_returns_sr_item_sk_bloom_filter))) and (ss_promo_sk BETWEEN DynamicValue(RS_177_promotion_p_promo_sk_min) AND DynamicValue(RS_177_promotion_p_promo_sk_max) and in_bloom_filter(ss_promo_sk, DynamicValue(RS_177_promotion_p_promo_sk_bloom_filter))) and (ss_sold_date_sk BETWEEN DynamicValue(RS_174_d1_d_date_sk_min) AND DynamicValue(RS_174_d1_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_174_d1_d_date_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_215_store_s_store_sk_min) AND DynamicValue(RS_215_store_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_215_store_s_store_sk_bloom_filter))) and (ss_ticket_number BETWEEN DynamicValue(RS_221_store_returns_sr_ticket_number_mi
n) AND DynamicValue(RS_221_store_returns_sr_ticket_number_max) and in_bloom_filter(ss_ticket_number, DynamicValue(RS_221_store_returns_sr_ticket_number_bloom_filter))) and ss_addr_sk is not null and ss_cdemo_sk is not null and ss_customer_sk is not null and ss_hdemo_sk is not null and ss_item_sk is not null and ss_promo_sk is not null and ss_sold_date_sk is not null and ss_store_sk is not null and ss_ticket_number is not null)
+ Filter Operator [FIL_1276] (rows=575995635 width=88)
+ predicate:((ss_addr_sk BETWEEN DynamicValue(RS_218_ad1_ca_address_sk_min) AND DynamicValue(RS_218_ad1_ca_address_sk_max) and in_bloom_filter(ss_addr_sk, DynamicValue(RS_218_ad1_ca_address_sk_bloom_filter))) and (ss_cdemo_sk BETWEEN DynamicValue(RS_246_cd1_cd_demo_sk_min) AND DynamicValue(RS_246_cd1_cd_demo_sk_max) and in_bloom_filter(ss_cdemo_sk, DynamicValue(RS_246_cd1_cd_demo_sk_bloom_filter))) and (ss_hdemo_sk BETWEEN DynamicValue(RS_208_hd1_hd_demo_sk_min) AND DynamicValue(RS_208_hd1_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_208_hd1_hd_demo_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_171_item_i_item_sk_min) AND DynamicValue(RS_171_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_171_item_i_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_212_catalog_sales_cs_item_sk_min) AND DynamicValue(RS_212_catalog_sales_cs_item_sk_max) and i
n_bloom_filter(ss_item_sk, DynamicValue(RS_212_catalog_sales_cs_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_221_store_returns_sr_item_sk_min) AND DynamicValue(RS_221_store_returns_sr_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_221_store_returns_sr_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_44_item_i_item_sk_min) AND DynamicValue(RS_44_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_44_item_i_item_sk_bloom_filter))) and (ss_promo_sk BETWEEN DynamicValue(RS_177_promotion_p_promo_sk_min) AND DynamicValue(RS_177_promotion_p_promo_sk_max) and in_bloom_filter(ss_promo_sk, DynamicValue(RS_177_promotion_p_promo_sk_bloom_filter))) and (ss_sold_date_sk BETWEEN DynamicValue(RS_174_d1_d_date_sk_min) AND DynamicValue(RS_174_d1_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_174_d1_d_date_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_215_store_s_store_sk_min) AND DynamicValue(RS_215_sto
re_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_215_store_s_store_sk_bloom_filter))) and (ss_ticket_number BETWEEN DynamicValue(RS_221_store_returns_sr_ticket_number_min) AND DynamicValue(RS_221_store_returns_sr_ticket_number_max) and in_bloom_filter(ss_ticket_number, DynamicValue(RS_221_store_returns_sr_ticket_number_bloom_filter))) and ss_addr_sk is not null and ss_cdemo_sk is not null and ss_customer_sk is not null and ss_hdemo_sk is not null and ss_item_sk is not null and ss_promo_sk is not null and ss_sold_date_sk is not null and ss_store_sk is not null and ss_ticket_number is not null)
TableScan [TS_158] (rows=575995635 width=88)
default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_customer_sk","ss_cdemo_sk","ss_hdemo_sk","ss_addr_sk","ss_store_sk","ss_promo_sk","ss_ticket_number","ss_wholesale_cost","ss_list_price","ss_coupon_amt"]
+ <-Reducer 43 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1148]
+ Group By Operator [GBY_1145] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
+ <-Map 42 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1143]
+ Group By Operator [GBY_1141] (rows=1 width=12)
+ Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
+ Select Operator [SEL_1138] (rows=2851 width=1436)
+ Output:["_col0"]
+ Please refer to the previous Select Operator [SEL_1136]
+ <-Reducer 45 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1241]
+ Please refer to the previous Group By Operator [GBY_1240]
+ <-Reducer 67 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1254]
+ Please refer to the previous Group By Operator [GBY_1253]
<-Reducer 31 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1206]
- Group By Operator [GBY_1205] (rows=1 width=12)
+ BROADCAST [RS_1244]
+ Group By Operator [GBY_1243] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 15 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1074]
- Group By Operator [GBY_1072] (rows=1 width=12)
+ PARTITION_ONLY_SHUFFLE [RS_1106]
+ Group By Operator [GBY_1104] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_1070] (rows=36524 width=1119)
+ Select Operator [SEL_1102] (rows=36524 width=1119)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1064]
+ Please refer to the previous Select Operator [SEL_1096]
<-Reducer 35 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1210]
- Group By Operator [GBY_1209] (rows=1 width=12)
+ BROADCAST [RS_1248]
+ Group By Operator [GBY_1247] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Reducer 33 [CUSTOM_SIMPLE_EDGE]
- SHUFFLE [RS_895]
- Group By Operator [GBY_894] (rows=1 width=12)
+ SHUFFLE [RS_909]
+ Group By Operator [GBY_908] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_893] (rows=7920 width=107)
+ Select Operator [SEL_907] (rows=7920 width=107)
Output:["_col0"]
- Please refer to the previous Merge Join Operator [MERGEJOIN_1021]
+ Please refer to the previous Merge Join Operator [MERGEJOIN_1053]
<-Reducer 39 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1218]
- Group By Operator [GBY_1217] (rows=1 width=12)
+ BROADCAST [RS_1271]
+ Group By Operator [GBY_1270] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=40000000)"]
<-Map 37 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1091]
- Group By Operator [GBY_1089] (rows=1 width=12)
+ SHUFFLE [RS_1123]
+ Group By Operator [GBY_1121] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=40000000)"]
- Select Operator [SEL_1087] (rows=40000000 width=1014)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1082]
- <-Reducer 45 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1204]
- Group By Operator [GBY_1203] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
- <-Map 42 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1112]
- Group By Operator [GBY_1110] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_1108] (rows=2851 width=1436)
+ Select Operator [SEL_1119] (rows=40000000 width=1014)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1104]
+ Please refer to the previous Select Operator [SEL_1114]
<-Reducer 48 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1208]
- Group By Operator [GBY_1207] (rows=1 width=12)
+ BROADCAST [RS_1246]
+ Group By Operator [GBY_1245] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
<-Map 46 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1126]
- Group By Operator [GBY_1124] (rows=1 width=12)
+ PARTITION_ONLY_SHUFFLE [RS_1160]
+ Group By Operator [GBY_1158] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_1122] (rows=2300 width=1179)
+ Select Operator [SEL_1156] (rows=2300 width=1179)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1118]
- <-Reducer 53 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1212]
- Group By Operator [GBY_1211] (rows=1 width=228)
+ Please refer to the previous Select Operator [SEL_1152]
+ <-Reducer 58 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1267]
+ Group By Operator [GBY_1266] (rows=1 width=228)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=52798136)"]
- <-Reducer 51 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1176]
- Group By Operator [GBY_1174] (rows=1 width=228)
+ <-Reducer 57 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1265]
+ Group By Operator [GBY_1264] (rows=1 width=228)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=52798136)"]
- Select Operator [SEL_1172] (rows=52798137 width=135)
+ Select Operator [SEL_1263] (rows=52798137 width=135)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1168]
- <-Reducer 59 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1216]
- Group By Operator [GBY_1215] (rows=1 width=12)
+ Please refer to the previous Select Operator [SEL_1261]
+ <-Reducer 63 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1269]
+ Group By Operator [GBY_1268] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
- <-Map 57 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1188]
- Group By Operator [GBY_1186] (rows=1 width=12)
+ <-Map 61 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1225]
+ Group By Operator [GBY_1223] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_1184] (rows=1704 width=1910)
+ Select Operator [SEL_1221] (rows=1704 width=1910)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1180]
- <-Reducer 63 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1214]
- Group By Operator [GBY_1213] (rows=1 width=12)
+ Please refer to the previous Select Operator [SEL_1217]
+ <-Reducer 68 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1273]
+ Group By Operator [GBY_1272] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=57591152)"]
- <-Map 60 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1158]
- Group By Operator [GBY_1154] (rows=1 width=12)
+ <-Map 64 [CUSTOM_SIMPLE_EDGE] vectorized
+ PARTITION_ONLY_SHUFFLE [RS_1200]
+ Group By Operator [GBY_1196] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=57591152)"]
- Select Operator [SEL_1150] (rows=57591150 width=77)
+ Select Operator [SEL_1192] (rows=57591150 width=77)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1145]
- <-Reducer 64 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1220]
- Group By Operator [GBY_1219] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=57591152)"]
- <-Map 60 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1159]
- Group By Operator [GBY_1155] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=57591152)"]
- Select Operator [SEL_1151] (rows=57591150 width=77)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1145]
- <-Reducer 67 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1222]
- Group By Operator [GBY_1221] (rows=1 width=12)
+ Please refer to the previous Select Operator [SEL_1186]
+ <-Reducer 71 [BROADCAST_EDGE] vectorized
+ BROADCAST [RS_1275]
+ Group By Operator [GBY_1274] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1861800)"]
- <-Map 65 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1102]
- Group By Operator [GBY_1100] (rows=1 width=12)
+ <-Map 69 [CUSTOM_SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_1134]
+ Group By Operator [GBY_1132] (rows=1 width=12)
Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1861800)"]
- Select Operator [SEL_1098] (rows=1861800 width=385)
+ Select Operator [SEL_1130] (rows=1861800 width=385)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1093]
+ Please refer to the previous Select Operator [SEL_1125]
<-Reducer 9 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1202]
+ SHUFFLE [RS_1239]
PartitionCols:_col2, _col1, _col3
- Select Operator [SEL_1201] (rows=746992327 width=88)
+ Select Operator [SEL_1238] (rows=746992327 width=88)
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15"]
-
<TRUNCATED>