http://git-wip-us.apache.org/repos/asf/hive/blob/0f7163fa/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 e3eea58..6b11fc2 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query64.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query64.q.out @@ -237,64 +237,64 @@ 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 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) +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) 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 12 <- Reducer 28 (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 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 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 2 <- Map 1 (SIMPLE_EDGE), Map 15 (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 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 3 <- Map 15 (SIMPLE_EDGE), Reducer 2 (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 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 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 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 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 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 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 70 <- Map 69 (CUSTOM_SIMPLE_EDGE) Reducer 71 <- Map 69 (CUSTOM_SIMPLE_EDGE) Reducer 8 <- Map 69 (SIMPLE_EDGE), Reducer 7 (SIMPLE_EDGE) @@ -305,8 +305,8 @@ Stage-0 limit:-1 Stage-1 Reducer 11 vectorized - File Output Operator [FS_1283] - Select Operator [SEL_1282] (rows=273897192 width=88) + File Output Operator [FS_1281] + Select Operator [SEL_1280] (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] @@ -314,688 +314,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_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"] + 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"] <-Reducer 14 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1281] + SHUFFLE [RS_1279] PartitionCols:_col1, _col0, _col2 - Select Operator [SEL_1280] (rows=746992327 width=88) + Select Operator [SEL_1278] (rows=746992327 width=88) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"] - Group By Operator [GBY_1279] (rows=746992327 width=88) + Group By Operator [GBY_1277] (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(_col43)","sum(_col44)","sum(_col45)"],keys:_col28, _col46, _col29, _col7, _col9, _col14, _col15, _col16, _col17, _col23, _col24, _col25, _col26, _col49 + 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 Select Operator [SEL_249] (rows=1493984654 width=88) - Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col49"] + Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col21","_col22","_col23","_col24","_col26","_col27","_col45","_col46","_col47","_col48","_col51"] Filter Operator [FIL_248] (rows=1493984654 width=88) predicate:(_col56 <> _col19) - 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"] + 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"] <-Map 69 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1129] + SHUFFLE [RS_1127] PartitionCols:_col0 - Select Operator [SEL_1125] (rows=1861800 width=385) + Select Operator [SEL_1123] (rows=1861800 width=385) Output:["_col0","_col1"] - Filter Operator [FIL_1124] (rows=1861800 width=385) + Filter Operator [FIL_1122] (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_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"] + 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"] <-Reducer 6 [SIMPLE_EDGE] SHUFFLE [RS_242] PartitionCols:_col0 - 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"] + 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"] <-Map 69 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1128] + SHUFFLE [RS_1126] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1125] + Please refer to the previous Select Operator [SEL_1123] <-Reducer 5 [SIMPLE_EDGE] SHUFFLE [RS_112] PartitionCols:_col1 - 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] + 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] PartitionCols:_col0 - Select Operator [SEL_1114] (rows=40000000 width=1014) + Select Operator [SEL_1112] (rows=40000000 width=1014) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_1113] (rows=40000000 width=1014) + Filter Operator [FIL_1111] (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_1054] (rows=106480005 width=860) + Merge Join Operator [MERGEJOIN_1052] (rows=106480005 width=860) Conds:RS_106._col2=RS_107._col0(Inner),Output:["_col0","_col1","_col3","_col7","_col9"] - <-Reducer 33 [SIMPLE_EDGE] + <-Reducer 31 [SIMPLE_EDGE] SHUFFLE [RS_107] PartitionCols:_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_1109] + 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] PartitionCols:_col1 - Select Operator [SEL_1108] (rows=7200 width=107) + Select Operator [SEL_1106] (rows=7200 width=107) Output:["_col0","_col1"] - Filter Operator [FIL_1107] (rows=7200 width=107) + Filter Operator [FIL_1105] (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_1112] + <-Map 34 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1110] PartitionCols:_col0 - Select Operator [SEL_1111] (rows=20 width=12) + Select Operator [SEL_1109] (rows=20 width=12) Output:["_col0"] - Filter Operator [FIL_1110] (rows=20 width=12) + Filter Operator [FIL_1108] (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_1052] (rows=96800003 width=860) - Conds:RS_103._col4=RS_1098._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col7","_col9"] + Merge Join Operator [MERGEJOIN_1050] (rows=96800003 width=860) + Conds:RS_103._col4=RS_1096._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col7","_col9"] <-Map 15 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1098] + SHUFFLE [RS_1096] PartitionCols:_col0 - Select Operator [SEL_1094] (rows=73049 width=1119) + Select Operator [SEL_1092] (rows=73049 width=1119) Output:["_col0","_col1"] - Filter Operator [FIL_1091] (rows=73049 width=1119) + Filter Operator [FIL_1089] (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_1051] (rows=88000001 width=860) - Conds:RS_1090._col5=RS_1097._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col7"] + Merge Join Operator [MERGEJOIN_1049] (rows=88000001 width=860) + Conds:RS_1088._col5=RS_1095._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col7"] <-Map 15 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1097] + SHUFFLE [RS_1095] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1094] + Please refer to the previous Select Operator [SEL_1092] <-Map 1 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1090] + SHUFFLE [RS_1088] PartitionCols:_col5 - Select Operator [SEL_1089] (rows=80000000 width=860) + Select Operator [SEL_1087] (rows=80000000 width=860) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_1088] (rows=80000000 width=860) + Filter Operator [FIL_1086] (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 30 [SIMPLE_EDGE] + <-Reducer 28 [SIMPLE_EDGE] SHUFFLE [RS_243] - PartitionCols:_col16 + PartitionCols:_col18 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_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] + 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] SHUFFLE [RS_220] - 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:_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:_col0 - Please refer to the previous Select Operator [SEL_1114] - <-Reducer 28 [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_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] SHUFFLE [RS_217] - 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:_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:_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_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] + 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] SHUFFLE [RS_214] - 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 - 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] + 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:_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 + 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] PartitionCols:_col0 - Select Operator [SEL_1152] (rows=2300 width=1179) + Select Operator [SEL_1094] (rows=36524 width=1119) Output:["_col0"] - 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] + 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] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1136] + Please refer to the previous Select Operator [SEL_1134] <-Map 72 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1278] + SHUFFLE [RS_1276] PartitionCols:_col1 - Select Operator [SEL_1277] (rows=575995635 width=88) + Select Operator [SEL_1275] (rows=575995635 width=88) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] - 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) + 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) 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) + <-Reducer 42 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1146] + Group By Operator [GBY_1143] (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) + <-Map 41 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1141] + Group By Operator [GBY_1139] (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) + Select Operator [SEL_1136] (rows=5703 width=1436) Output:["_col0"] - Please refer to the previous Select Operator [SEL_1136] + Please refer to the previous Select Operator [SEL_1134] <-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_1244] - Group By Operator [GBY_1243] (rows=1 width=12) + 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) 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_1106] - Group By Operator [GBY_1104] (rows=1 width=12) + SHUFFLE [RS_1104] + Group By Operator [GBY_1102] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_1102] (rows=36524 width=1119) + Select Operator [SEL_1100] (rows=36524 width=1119) Output:["_col0"] - 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) + 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) Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Reducer 33 [CUSTOM_SIMPLE_EDGE] - SHUFFLE [RS_909] - Group By Operator [GBY_908] (rows=1 width=12) + <-Reducer 31 [CUSTOM_SIMPLE_EDGE] + SHUFFLE [RS_916] + Group By Operator [GBY_915] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_907] (rows=7920 width=107) + Select Operator [SEL_914] (rows=7920 width=107) Output:["_col0"] - Please refer to the previous Merge Join Operator [MERGEJOIN_1053] - <-Reducer 39 [BROADCAST_EDGE] vectorized + Please refer to the previous Merge Join Operator [MERGEJOIN_1051] + <-Reducer 37 [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 37 [CUSTOM_SIMPLE_EDGE] vectorized - SHUFFLE [RS_1123] - Group By Operator [GBY_1121] (rows=1 width=12) + <-Map 35 [CUSTOM_SIMPLE_EDGE] vectorized + SHUFFLE [RS_1121] + Group By Operator [GBY_1119] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=40000000)"] - Select Operator [SEL_1119] (rows=40000000 width=1014) + Select Operator [SEL_1117] (rows=40000000 width=1014) Output:["_col0"] - 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)"] + 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)"] <-Map 46 [CUSTOM_SIMPLE_EDGE] vectorized -
<TRUNCATED>
