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/17 17:33:48 UTC
[03/12] hive git commit: HIVE-20716: Set default value for
hive.cbo.stats.correlated.multi.key.joins to true (Jesus Camacho Rodriguez,
reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/a22e7dd9/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 e04a1c8..402dade 100644
--- a/ql/src/test/results/clientpositive/perf/tez/query64.q.out
+++ b/ql/src/test/results/clientpositive/perf/tez/query64.q.out
@@ -265,64 +265,64 @@ POSTHOOK: Output: hdfs://### HDFS PATH ###
Plan optimized by CBO.
Vertex dependency in root stage
-Map 38 <- Reducer 22 (BROADCAST_EDGE), Reducer 32 (BROADCAST_EDGE), Reducer 36 (BROADCAST_EDGE), Reducer 42 (BROADCAST_EDGE), Reducer 47 (BROADCAST_EDGE), Reducer 48 (BROADCAST_EDGE), Reducer 52 (BROADCAST_EDGE), Reducer 57 (BROADCAST_EDGE), Reducer 67 (BROADCAST_EDGE), Reducer 70 (BROADCAST_EDGE)
-Map 54 <- Reducer 42 (BROADCAST_EDGE), Reducer 47 (BROADCAST_EDGE), Reducer 59 (BROADCAST_EDGE), Reducer 60 (BROADCAST_EDGE)
-Map 72 <- Reducer 29 (BROADCAST_EDGE), Reducer 33 (BROADCAST_EDGE), Reducer 37 (BROADCAST_EDGE), Reducer 42 (BROADCAST_EDGE), Reducer 45 (BROADCAST_EDGE), Reducer 49 (BROADCAST_EDGE), Reducer 50 (BROADCAST_EDGE), Reducer 53 (BROADCAST_EDGE), Reducer 63 (BROADCAST_EDGE), Reducer 68 (BROADCAST_EDGE), Reducer 71 (BROADCAST_EDGE)
-Map 73 <- Reducer 45 (BROADCAST_EDGE), Reducer 49 (BROADCAST_EDGE), Reducer 64 (BROADCAST_EDGE), Reducer 65 (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 28 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE)
+Reducer 12 <- Reducer 30 (SIMPLE_EDGE), Reducer 6 (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 40 (SIMPLE_EDGE)
-Reducer 17 <- Map 51 (SIMPLE_EDGE), Reducer 16 (SIMPLE_EDGE)
-Reducer 18 <- Reducer 17 (SIMPLE_EDGE), Reducer 31 (SIMPLE_EDGE)
-Reducer 19 <- Reducer 18 (SIMPLE_EDGE), Reducer 56 (ONE_TO_ONE_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 66 (SIMPLE_EDGE), Reducer 19 (SIMPLE_EDGE)
-Reducer 21 <- Map 35 (SIMPLE_EDGE), Reducer 20 (SIMPLE_EDGE)
-Reducer 22 <- Map 15 (CUSTOM_SIMPLE_EDGE)
-Reducer 23 <- Map 15 (SIMPLE_EDGE), Reducer 44 (SIMPLE_EDGE)
-Reducer 24 <- Map 51 (SIMPLE_EDGE), Reducer 23 (SIMPLE_EDGE)
-Reducer 25 <- Reducer 24 (SIMPLE_EDGE), Reducer 31 (SIMPLE_EDGE)
-Reducer 26 <- Reducer 25 (SIMPLE_EDGE), Reducer 62 (ONE_TO_ONE_EDGE)
-Reducer 27 <- Map 66 (SIMPLE_EDGE), Reducer 26 (SIMPLE_EDGE)
-Reducer 28 <- Map 35 (SIMPLE_EDGE), Reducer 27 (SIMPLE_EDGE)
-Reducer 29 <- Map 15 (CUSTOM_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 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 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 31 <- Map 30 (SIMPLE_EDGE), Map 34 (SIMPLE_EDGE)
-Reducer 32 <- Reducer 31 (CUSTOM_SIMPLE_EDGE)
-Reducer 33 <- Reducer 31 (CUSTOM_SIMPLE_EDGE)
-Reducer 36 <- Map 35 (CUSTOM_SIMPLE_EDGE)
-Reducer 37 <- Map 35 (CUSTOM_SIMPLE_EDGE)
-Reducer 39 <- Map 38 (SIMPLE_EDGE), Map 41 (SIMPLE_EDGE)
-Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 31 (SIMPLE_EDGE)
-Reducer 40 <- Map 46 (SIMPLE_EDGE), Reducer 39 (SIMPLE_EDGE)
-Reducer 42 <- Map 41 (CUSTOM_SIMPLE_EDGE)
-Reducer 43 <- Map 41 (SIMPLE_EDGE), Map 72 (SIMPLE_EDGE)
-Reducer 44 <- Map 46 (SIMPLE_EDGE), Reducer 43 (SIMPLE_EDGE)
-Reducer 45 <- Map 41 (CUSTOM_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)
+Reducer 35 <- Reducer 33 (CUSTOM_SIMPLE_EDGE)
+Reducer 38 <- Map 37 (CUSTOM_SIMPLE_EDGE)
+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 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 49 <- Map 46 (CUSTOM_SIMPLE_EDGE)
-Reducer 5 <- Map 35 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE)
-Reducer 50 <- Map 46 (CUSTOM_SIMPLE_EDGE)
-Reducer 52 <- Map 51 (CUSTOM_SIMPLE_EDGE)
-Reducer 53 <- Map 51 (CUSTOM_SIMPLE_EDGE)
-Reducer 55 <- Map 54 (SIMPLE_EDGE), Map 58 (SIMPLE_EDGE)
-Reducer 56 <- Reducer 55 (SIMPLE_EDGE)
-Reducer 57 <- Reducer 56 (CUSTOM_SIMPLE_EDGE)
-Reducer 59 <- Map 58 (CUSTOM_SIMPLE_EDGE)
+Reducer 5 <- Map 37 (SIMPLE_EDGE), Reducer 4 (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 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 58 (CUSTOM_SIMPLE_EDGE)
-Reducer 61 <- Map 58 (SIMPLE_EDGE), Map 73 (SIMPLE_EDGE)
-Reducer 62 <- Reducer 61 (SIMPLE_EDGE)
-Reducer 63 <- Reducer 62 (CUSTOM_SIMPLE_EDGE)
-Reducer 64 <- Map 58 (CUSTOM_SIMPLE_EDGE)
-Reducer 65 <- Map 58 (CUSTOM_SIMPLE_EDGE)
-Reducer 67 <- Map 66 (CUSTOM_SIMPLE_EDGE)
-Reducer 68 <- Map 66 (CUSTOM_SIMPLE_EDGE)
-Reducer 7 <- Reducer 21 (SIMPLE_EDGE), Reducer 6 (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 70 <- Map 69 (CUSTOM_SIMPLE_EDGE)
Reducer 71 <- Map 69 (CUSTOM_SIMPLE_EDGE)
Reducer 8 <- Map 69 (SIMPLE_EDGE), Reducer 7 (SIMPLE_EDGE)
@@ -333,8 +333,8 @@ Stage-0
limit:-1
Stage-1
Reducer 11 vectorized
- File Output Operator [FS_1281]
- Select Operator [SEL_1280] (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]
@@ -342,688 +342,688 @@ 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_1085] (rows=821691577 width=88)
- Conds:RS_1237._col2, _col1, _col3=RS_1279._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_1279]
+ SHUFFLE [RS_1281]
PartitionCols:_col1, _col0, _col2
- Select Operator [SEL_1278] (rows=746992327 width=88)
+ Select Operator [SEL_1280] (rows=746992327 width=88)
Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"]
- Group By Operator [GBY_1277] (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]
PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, _col11, _col12, _col13
Group By Operator [GBY_250] (rows=1493984654 width=88)
- Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15","_col16","_col17"],aggregations:["count()","sum(_col45)","sum(_col46)","sum(_col47)"],keys:_col26, _col48, _col27, _col7, _col9, _col14, _col15, _col16, _col17, _col21, _col22, _col23, _col24, _col51
+ Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15","_col16","_col17"],aggregations:["count()","sum(_col43)","sum(_col44)","sum(_col45)"],keys:_col28, _col46, _col29, _col7, _col9, _col14, _col15, _col16, _col17, _col23, _col24, _col25, _col26, _col49
Select Operator [SEL_249] (rows=1493984654 width=88)
- Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col21","_col22","_col23","_col24","_col26","_col27","_col45","_col46","_col47","_col48","_col51"]
+ 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_1084] (rows=1493984654 width=88)
- Conds:RS_245._col39=RS_1127._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col21","_col22","_col23","_col24","_col26","_col27","_col45","_col46","_col47","_col48","_col51","_col56"]
+ 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_1127]
+ SHUFFLE [RS_1129]
PartitionCols:_col0
- Select Operator [SEL_1123] (rows=1861800 width=385)
+ Select Operator [SEL_1125] (rows=1861800 width=385)
Output:["_col0","_col1"]
- Filter Operator [FIL_1122] (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:_col39
- Merge Join Operator [MERGEJOIN_1083] (rows=1358167838 width=88)
- Conds:RS_242._col0=RS_243._col18(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col21","_col22","_col23","_col24","_col26","_col27","_col39","_col45","_col46","_col47","_col48","_col51"]
+ PartitionCols:_col37
+ 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_1054] (rows=128840811 width=860)
- Conds:RS_112._col1=RS_1126._col0(Inner),Output:["_col0","_col7","_col9","_col14","_col15","_col16","_col17","_col19"]
+ 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_1126]
+ SHUFFLE [RS_1128]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_1123]
+ Please refer to the previous Select Operator [SEL_1125]
<-Reducer 5 [SIMPLE_EDGE]
SHUFFLE [RS_112]
PartitionCols:_col1
- Merge Join Operator [MERGEJOIN_1053] (rows=117128008 width=860)
- Conds:RS_109._col3=RS_1113._col0(Inner),Output:["_col0","_col1","_col7","_col9","_col14","_col15","_col16","_col17"]
- <-Map 35 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1113]
+ 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_1115]
PartitionCols:_col0
- Select Operator [SEL_1112] (rows=40000000 width=1014)
+ Select Operator [SEL_1114] (rows=40000000 width=1014)
Output:["_col0","_col1","_col2","_col3","_col4"]
- Filter Operator [FIL_1111] (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_1052] (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 31 [SIMPLE_EDGE]
+ <-Reducer 33 [SIMPLE_EDGE]
SHUFFLE [RS_107]
PartitionCols:_col0
- Merge Join Operator [MERGEJOIN_1051] (rows=7920 width=107)
- Conds:RS_1107._col1=RS_1110._col0(Inner),Output:["_col0"]
- <-Map 30 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1107]
+ 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_1109]
PartitionCols:_col1
- Select Operator [SEL_1106] (rows=7200 width=107)
+ Select Operator [SEL_1108] (rows=7200 width=107)
Output:["_col0","_col1"]
- Filter Operator [FIL_1105] (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 34 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1110]
+ <-Map 36 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_1112]
PartitionCols:_col0
- Select Operator [SEL_1109] (rows=20 width=12)
+ Select Operator [SEL_1111] (rows=20 width=12)
Output:["_col0"]
- Filter Operator [FIL_1108] (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_1050] (rows=96800003 width=860)
- Conds:RS_103._col4=RS_1096._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
- SHUFFLE [RS_1096]
+ PARTITION_ONLY_SHUFFLE [RS_1098]
PartitionCols:_col0
- Select Operator [SEL_1092] (rows=73049 width=1119)
+ Select Operator [SEL_1094] (rows=73049 width=1119)
Output:["_col0","_col1"]
- Filter Operator [FIL_1089] (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_1049] (rows=88000001 width=860)
- Conds:RS_1088._col5=RS_1095._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
- SHUFFLE [RS_1095]
+ PARTITION_ONLY_SHUFFLE [RS_1097]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_1092]
+ Please refer to the previous Select Operator [SEL_1094]
<-Map 1 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1088]
+ SHUFFLE [RS_1090]
PartitionCols:_col5
- Select Operator [SEL_1087] (rows=80000000 width=860)
+ Select Operator [SEL_1089] (rows=80000000 width=860)
Output:["_col0","_col1","_col2","_col3","_col4","_col5"]
- Filter Operator [FIL_1086] (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"]
- <-Reducer 28 [SIMPLE_EDGE]
+ <-Reducer 30 [SIMPLE_EDGE]
SHUFFLE [RS_243]
- PartitionCols:_col18
+ PartitionCols:_col16
Select Operator [SEL_223] (rows=1234698008 width=88)
- Output:["_col1","_col2","_col3","_col4","_col6","_col7","_col18","_col19","_col25","_col26","_col27","_col28","_col31"]
- Merge Join Operator [MERGEJOIN_1082] (rows=1234698008 width=88)
- Conds:RS_220._col13=RS_1116._col0(Inner),Output:["_col10","_col11","_col17","_col18","_col19","_col20","_col23","_col28","_col29","_col31","_col32","_col33","_col34"]
- <-Map 35 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1116]
- PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_1112]
- <-Reducer 27 [SIMPLE_EDGE]
+ Output:["_col3","_col4","_col5","_col6","_col8","_col9","_col16","_col17","_col23","_col24","_col25","_col26","_col29"]
+ 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_1186] (rows=57591150 width=77)
+ Output:["_col0","_col1"]
+ 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:_col13
- Merge Join Operator [MERGEJOIN_1081] (rows=1122452711 width=88)
- Conds:RS_217._col14=RS_1220._col0(Inner),Output:["_col10","_col11","_col13","_col17","_col18","_col19","_col20","_col23","_col28","_col29"]
- <-Map 66 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1220]
+ PartitionCols:_col5, _col12
+ 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_1118]
PartitionCols:_col0
- Select Operator [SEL_1217] (rows=1704 width=1910)
- Output:["_col0","_col1","_col2"]
- 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_75] (rows=1704 width=1910)
- default@store,store,Tbl:COMPLETE,Col:NONE,Output:["s_store_sk","s_store_name","s_zip"]
- <-Reducer 26 [SIMPLE_EDGE]
+ Please refer to the previous Select Operator [SEL_1114]
+ <-Reducer 28 [SIMPLE_EDGE]
SHUFFLE [RS_217]
- PartitionCols:_col14
- Merge Join Operator [MERGEJOIN_1080] (rows=1020411534 width=88)
- Conds:RS_214._col9=RS_1262._col0(Inner),Output:["_col10","_col11","_col13","_col14","_col17","_col18","_col19","_col20","_col23"]
- <-Reducer 62 [ONE_TO_ONE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1262]
+ PartitionCols:_col9
+ 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_1261] (rows=52798137 width=135)
- Output:["_col0"]
- Filter Operator [FIL_1260] (rows=52798137 width=135)
- predicate:(_col1 > (2 * _col2))
- Group By Operator [GBY_1259] (rows=158394413 width=135)
- Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0
- <-Reducer 61 [SIMPLE_EDGE]
- SHUFFLE [RS_198]
- PartitionCols:_col0
- Group By Operator [GBY_197] (rows=316788826 width=135)
- Output:["_col0","_col1","_col2"],aggregations:["sum(_col1)","sum(_col2)"],keys:_col0
- Select Operator [SEL_195] (rows=316788826 width=135)
- Output:["_col0","_col1","_col2"]
- Merge Join Operator [MERGEJOIN_1078] (rows=316788826 width=135)
- Conds:RS_1258._col0, _col1=RS_1173._col0, _col1(Inner),Output:["_col0","_col2","_col5","_col6","_col7"]
- <-Map 58 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1173]
- PartitionCols:_col0, _col1
- Select Operator [SEL_1169] (rows=28798881 width=106)
- Output:["_col0","_col1","_col2","_col3","_col4"]
- Filter Operator [FIL_1168] (rows=28798881 width=106)
- predicate:(cr_item_sk is not null and cr_order_number is not null)
- TableScan [TS_62] (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 73 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1258]
- PartitionCols:_col0, _col1
- Select Operator [SEL_1257] (rows=287989836 width=135)
- Output:["_col0","_col1","_col2"]
- Filter Operator [FIL_1256] (rows=287989836 width=135)
- predicate:((cs_item_sk BETWEEN DynamicValue(RS_174_item_i_item_sk_min) AND DynamicValue(RS_174_item_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_174_item_i_item_sk_bloom_filter))) and (cs_item_sk BETWEEN DynamicValue(RS_177_store_returns_sr_item_sk_min) AND DynamicValue(RS_177_store_returns_sr_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_177_store_returns_sr_item_sk_bloom_filter))) and (cs_item_sk BETWEEN DynamicValue(RS_193_catalog_returns_cr_item_sk_min) AND DynamicValue(RS_193_catalog_returns_cr_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_193_catalog_returns_cr_item_sk_bloom_filter))) and (cs_order_number BETWEEN DynamicValue(RS_193_catalog_returns_cr_order_number_min) AND DynamicValue(RS_193_catalog_returns_cr_order_number_max) and in_bloom_filter(cs_order_number, DynamicValue(RS_193_catalog_returns_cr_order_number_bloom_filter))) and cs_item_sk is not nul
l and cs_order_number is not null)
- TableScan [TS_186] (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 45 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1240]
- Group By Operator [GBY_1238] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"]
- <-Map 41 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1142]
- Group By Operator [GBY_1140] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
- Select Operator [SEL_1138] (rows=5703 width=1436)
- Output:["_col0"]
- Select Operator [SEL_1134] (rows=5703 width=1436)
- Output:["_col0","_col3"]
- Filter Operator [FIL_1133] (rows=5703 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 49 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1243]
- Group By Operator [GBY_1241] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=57591152)"]
- <-Map 46 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1161]
- Group By Operator [GBY_1157] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=57591152)"]
- Select Operator [SEL_1153] (rows=57591150 width=77)
- Output:["_col0"]
- Select Operator [SEL_1148] (rows=57591150 width=77)
- Output:["_col0","_col1"]
- Filter Operator [FIL_1147] (rows=57591150 width=77)
- predicate:(sr_item_sk is not null and sr_ticket_number is not null)
- TableScan [TS_37] (rows=57591150 width=77)
- default@store_returns,store_returns,Tbl:COMPLETE,Col:NONE,Output:["sr_item_sk","sr_ticket_number"]
- <-Reducer 64 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1253]
- Group By Operator [GBY_1252] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=28798880)"]
- <-Map 58 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1182]
- Group By Operator [GBY_1178] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=28798880)"]
- Select Operator [SEL_1174] (rows=28798881 width=106)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1169]
- <-Reducer 65 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1255]
- Group By Operator [GBY_1254] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=28798880)"]
- <-Map 58 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1183]
- Group By Operator [GBY_1179] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=28798880)"]
- Select Operator [SEL_1175] (rows=28798881 width=106)
- Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1169]
- <-Reducer 25 [SIMPLE_EDGE]
+ Select Operator [SEL_1217] (rows=1704 width=1910)
+ Output:["_col0","_col1","_col2"]
+ 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:_col9
- Merge Join Operator [MERGEJOIN_1079] (rows=927646829 width=88)
- Conds:RS_211._col0=RS_212._col9(Inner),Output:["_col9","_col10","_col11","_col13","_col14","_col17","_col18","_col19","_col20","_col23"]
- <-Reducer 31 [SIMPLE_EDGE]
- SHUFFLE [RS_211]
+ PartitionCols:_col10
+ 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
- Please refer to the previous Merge Join Operator [MERGEJOIN_1051]
- <-Reducer 24 [SIMPLE_EDGE]
- SHUFFLE [RS_212]
- PartitionCols:_col9
- Select Operator [SEL_185] (rows=843315281 width=88)
- Output:["_col6","_col7","_col8","_col9","_col10","_col11","_col14","_col15","_col16","_col17","_col20"]
- Merge Join Operator [MERGEJOIN_1077] (rows=843315281 width=88)
- Conds:RS_182._col7=RS_1206._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col9","_col10","_col11","_col12","_col15"]
- <-Map 51 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1206]
- PartitionCols:_col0
- Select Operator [SEL_1203] (rows=2300 width=1179)
- Output:["_col0"]
- Filter Operator [FIL_1202] (rows=2300 width=1179)
- predicate:p_promo_sk is not null
- TableScan [TS_43] (rows=2300 width=1179)
- default@promotion,promotion,Tbl:COMPLETE,Col:NONE,Output:["p_promo_sk"]
- <-Reducer 23 [SIMPLE_EDGE]
- SHUFFLE [RS_182]
- PartitionCols:_col7
- Merge Join Operator [MERGEJOIN_1076] (rows=766650239 width=88)
- Conds:RS_179._col0=RS_1099._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col9","_col10","_col11","_col12","_col15"]
- <-Map 15 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1099]
+ Select Operator [SEL_1261] (rows=52798137 width=135)
+ Output:["_col0"]
+ Filter Operator [FIL_1260] (rows=52798137 width=135)
+ predicate:(_col1 > (2 * _col2))
+ Group By Operator [GBY_1259] (rows=158394413 width=135)
+ Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0
+ <-Reducer 56 [SIMPLE_EDGE]
+ SHUFFLE [RS_192]
+ PartitionCols:_col0
+ Group By Operator [GBY_191] (rows=316788826 width=135)
+ Output:["_col0","_col1","_col2"],aggregations:["sum(_col1)","sum(_col2)"],keys:_col0
+ Select Operator [SEL_189] (rows=316788826 width=135)
+ Output:["_col0","_col1","_col2"]
+ 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_1166] (rows=28798881 width=106)
+ Output:["_col0","_col1","_col2","_col3","_col4"]
+ 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 73 [SIMPLE_EDGE] vectorized
+ SHUFFLE [RS_1258]
+ PartitionCols:_col0, _col1
+ Select Operator [SEL_1257] (rows=287989836 width=135)
+ Output:["_col0","_col1","_col2"]
+ 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 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=5703 width=1436)
+ Output:["_col0"]
+ Select Operator [SEL_1136] (rows=5703 width=1436)
+ Output:["_col0","_col3"]
+ Filter Operator [FIL_1135] (rows=5703 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 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_1191] (rows=57591150 width=77)
+ Output:["_col0"]
+ 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 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_1171] (rows=28798881 width=106)
+ Output:["_col0"]
+ 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 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_1172] (rows=28798881 width=106)
+ Output:["_col0"]
+ Please refer to the previous Select Operator [SEL_1166]
+ <-Reducer 26 [SIMPLE_EDGE]
+ SHUFFLE [RS_211]
+ PartitionCols:_col5
+ 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_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_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_1155]
PartitionCols:_col0
- Select Operator [SEL_1094] (rows=36524 width=1119)
+ Select Operator [SEL_1152] (rows=2300 width=1179)
Output:["_col0"]
- Filter Operator [FIL_1091] (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_179]
- PartitionCols:_col0
- Merge Join Operator [MERGEJOIN_1075] (rows=696954748 width=88)
- Conds:RS_176._col1, _col8=RS_1152._col0, _col1(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col9","_col10","_col11","_col12","_col15"]
- <-Map 46 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1152]
- PartitionCols:_col0, _col1
- Please refer to the previous Select Operator [SEL_1148]
- <-Reducer 43 [SIMPLE_EDGE]
- SHUFFLE [RS_176]
- PartitionCols:_col1, _col8
- Merge Join Operator [MERGEJOIN_1074] (rows=633595212 width=88)
- Conds:RS_1276._col1=RS_1137._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col15"]
- <-Map 41 [SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1137]
+ 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_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_1101]
+ PartitionCols:_col0
+ Select Operator [SEL_1096] (rows=36524 width=1119)
+ Output:["_col0"]
+ 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_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_1139]
PartitionCols:_col0
- Please refer to the previous Select Operator [SEL_1134]
+ Please refer to the previous Select Operator [SEL_1136]
<-Map 72 [SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1276]
+ SHUFFLE [RS_1278]
PartitionCols:_col1
- Select Operator [SEL_1275] (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_1274] (rows=575995635 width=88)
- predicate:((ss_addr_sk BETWEEN DynamicValue(RS_221_ad1_ca_address_sk_min) AND DynamicValue(RS_221_ad1_ca_address_sk_max) and in_bloom_filter(ss_addr_sk, DynamicValue(RS_221_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_211_hd1_hd_demo_sk_min) AND DynamicValue(RS_211_hd1_hd_demo_sk_max) and in_bloom_filter(ss_hdemo_sk, DynamicValue(RS_211_hd1_hd_demo_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_174_item_i_item_sk_min) AND DynamicValue(RS_174_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_174_item_i_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_177_store_returns_sr_item_sk_min) AND DynamicValue(RS_177_store_returns_sr_item_sk_max) and i
n_bloom_filter(ss_item_sk, DynamicValue(RS_177_store_returns_sr_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_215_catalog_sales_cs_item_sk_min) AND DynamicValue(RS_215_catalog_sales_cs_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_215_catalog_sales_cs_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_47_item_i_item_sk_min) AND DynamicValue(RS_47_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_47_item_i_item_sk_bloom_filter))) and (ss_promo_sk BETWEEN DynamicValue(RS_183_promotion_p_promo_sk_min) AND DynamicValue(RS_183_promotion_p_promo_sk_max) and in_bloom_filter(ss_promo_sk, DynamicValue(RS_183_promotion_p_promo_sk_bloom_filter))) and (ss_sold_date_sk BETWEEN DynamicValue(RS_180_d1_d_date_sk_min) AND DynamicValue(RS_180_d1_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_180_d1_d_date_sk_bloom_filter))) and (ss_store_sk BETWEEN DynamicValue(RS_218_store_s_store_sk_min) AND DynamicValue(RS_218_sto
re_s_store_sk_max) and in_bloom_filter(ss_store_sk, DynamicValue(RS_218_store_s_store_sk_bloom_filter))) and (ss_ticket_number BETWEEN DynamicValue(RS_177_store_returns_sr_ticket_number_min) AND DynamicValue(RS_177_store_returns_sr_ticket_number_max) and in_bloom_filter(ss_ticket_number, DynamicValue(RS_177_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 42 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1146]
- Group By Operator [GBY_1143] (rows=1 width=12)
+ <-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 41 [CUSTOM_SIMPLE_EDGE] vectorized
- PARTITION_ONLY_SHUFFLE [RS_1141]
- Group By Operator [GBY_1139] (rows=1 width=12)
+ <-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_1136] (rows=5703 width=1436)
+ Select Operator [SEL_1138] (rows=5703 width=1436)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1134]
+ Please refer to the previous Select Operator [SEL_1136]
<-Reducer 45 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1239]
- Please refer to the previous Group By Operator [GBY_1238]
- <-Reducer 49 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1242]
- Please refer to the previous Group By Operator [GBY_1241]
- <-Reducer 29 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1247]
- Group By Operator [GBY_1246] (rows=1 width=12)
+ 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_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
- SHUFFLE [RS_1104]
- Group By Operator [GBY_1102] (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_1100] (rows=36524 width=1119)
+ Select Operator [SEL_1102] (rows=36524 width=1119)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1094]
- <-Reducer 33 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1251]
- Group By Operator [GBY_1250] (rows=1 width=12)
+ Please refer to the previous Select Operator [SEL_1096]
+ <-Reducer 35 [BROADCAST_EDGE] vectorized
+ 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 31 [CUSTOM_SIMPLE_EDGE]
- SHUFFLE [RS_916]
- Group By Operator [GBY_915] (rows=1 width=12)
+ <-Reducer 33 [CUSTOM_SIMPLE_EDGE]
+ 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_914] (rows=7920 width=107)
+ Select Operator [SEL_907] (rows=7920 width=107)
Output:["_col0"]
- Please refer to the previous Merge Join Operator [MERGEJOIN_1051]
- <-Reducer 37 [BROADCAST_EDGE] vectorized
+ Please refer to the previous Merge Join Operator [MERGEJOIN_1053]
+ <-Reducer 39 [BROADCAST_EDGE] vectorized
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 35 [CUSTOM_SIMPLE_EDGE] vectorized
- SHUFFLE [RS_1121]
- Group By Operator [GBY_1119] (rows=1 width=12)
+ <-Map 37 [CUSTOM_SIMPLE_EDGE] vectorized
+ 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_1117] (rows=40000000 width=1014)
+ Select Operator [SEL_1119] (rows=40000000 width=1014)
Output:["_col0"]
- Please refer to the previous Select Operator [SEL_1112]
- <-Reducer 50 [BROADCAST_EDGE] vectorized
- BROADCAST [RS_1245]
- Group By Operator [GBY_1244] (rows=1 width=12)
- Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=57591152)"]
+ Please refer to the previous Select Operator [SEL_1114]
+ <-Reducer 48 [BROADCAST_EDGE] vectorized
+ 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
-
<TRUNCATED>