http://git-wip-us.apache.org/repos/asf/hive/blob/e986fc56/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 7c77e9f..0010c469 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query64.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query64.q.out @@ -265,50 +265,45 @@ POSTHOOK: Output: hdfs://### HDFS PATH ### Plan optimized by CBO. Vertex dependency in root stage -Map 37 <- Reducer 24 (BROADCAST_EDGE), Reducer 40 (BROADCAST_EDGE), Reducer 46 (BROADCAST_EDGE) -Map 43 <- Reducer 40 (BROADCAST_EDGE) -Map 55 <- Reducer 12 (BROADCAST_EDGE), Reducer 32 (BROADCAST_EDGE), Reducer 42 (BROADCAST_EDGE), Reducer 50 (BROADCAST_EDGE) -Map 56 <- Reducer 42 (BROADCAST_EDGE) -Reducer 10 <- Reducer 15 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE) +Map 34 <- Reducer 37 (BROADCAST_EDGE) +Map 40 <- Reducer 37 (BROADCAST_EDGE) +Map 50 <- Reducer 39 (BROADCAST_EDGE) +Map 51 <- Reducer 39 (BROADCAST_EDGE) +Reducer 10 <- Reducer 14 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE) Reducer 11 <- Reducer 10 (SIMPLE_EDGE) -Reducer 12 <- Reducer 9 (CUSTOM_SIMPLE_EDGE) -Reducer 13 <- Reducer 31 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE) -Reducer 14 <- Map 54 (SIMPLE_EDGE), Reducer 13 (SIMPLE_EDGE) -Reducer 15 <- Reducer 14 (SIMPLE_EDGE) -Reducer 17 <- Map 16 (SIMPLE_EDGE), Reducer 38 (SIMPLE_EDGE) -Reducer 18 <- Reducer 17 (SIMPLE_EDGE), Reducer 45 (ONE_TO_ONE_EDGE) -Reducer 19 <- Map 51 (SIMPLE_EDGE), Reducer 18 (SIMPLE_EDGE) -Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 16 (SIMPLE_EDGE) -Reducer 20 <- Reducer 19 (SIMPLE_EDGE), Reducer 34 (SIMPLE_EDGE) -Reducer 21 <- Map 52 (SIMPLE_EDGE), Reducer 20 (SIMPLE_EDGE) -Reducer 22 <- Map 36 (SIMPLE_EDGE), Reducer 21 (SIMPLE_EDGE) -Reducer 23 <- Map 53 (SIMPLE_EDGE), Reducer 22 (SIMPLE_EDGE) -Reducer 24 <- Map 16 (CUSTOM_SIMPLE_EDGE) -Reducer 25 <- Map 16 (SIMPLE_EDGE), Reducer 41 (SIMPLE_EDGE) -Reducer 26 <- Reducer 25 (SIMPLE_EDGE), Reducer 49 (ONE_TO_ONE_EDGE) -Reducer 27 <- Map 51 (SIMPLE_EDGE), Reducer 26 (SIMPLE_EDGE) -Reducer 28 <- Reducer 27 (SIMPLE_EDGE), Reducer 34 (SIMPLE_EDGE) -Reducer 29 <- Map 52 (SIMPLE_EDGE), Reducer 28 (SIMPLE_EDGE) -Reducer 3 <- Map 16 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE) -Reducer 30 <- Map 36 (SIMPLE_EDGE), Reducer 29 (SIMPLE_EDGE) -Reducer 31 <- Map 53 (SIMPLE_EDGE), Reducer 30 (SIMPLE_EDGE) -Reducer 32 <- Map 16 (CUSTOM_SIMPLE_EDGE) -Reducer 34 <- Map 33 (SIMPLE_EDGE), Map 35 (SIMPLE_EDGE) -Reducer 38 <- Map 37 (SIMPLE_EDGE), Map 39 (SIMPLE_EDGE) -Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 34 (SIMPLE_EDGE) -Reducer 40 <- Map 39 (CUSTOM_SIMPLE_EDGE) -Reducer 41 <- Map 39 (SIMPLE_EDGE), Map 55 (SIMPLE_EDGE) -Reducer 42 <- Map 39 (CUSTOM_SIMPLE_EDGE) -Reducer 44 <- Map 43 (SIMPLE_EDGE), Map 47 (SIMPLE_EDGE) +Reducer 12 <- Reducer 29 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE) +Reducer 13 <- Map 49 (SIMPLE_EDGE), Reducer 12 (SIMPLE_EDGE) +Reducer 14 <- Reducer 13 (SIMPLE_EDGE) +Reducer 16 <- Map 15 (SIMPLE_EDGE), Reducer 35 (SIMPLE_EDGE) +Reducer 17 <- Reducer 16 (SIMPLE_EDGE), Reducer 42 (ONE_TO_ONE_EDGE) +Reducer 18 <- Map 46 (SIMPLE_EDGE), Reducer 17 (SIMPLE_EDGE) +Reducer 19 <- Reducer 18 (SIMPLE_EDGE), Reducer 31 (SIMPLE_EDGE) +Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 15 (SIMPLE_EDGE) +Reducer 20 <- Map 47 (SIMPLE_EDGE), Reducer 19 (SIMPLE_EDGE) +Reducer 21 <- Map 33 (SIMPLE_EDGE), Reducer 20 (SIMPLE_EDGE) +Reducer 22 <- Map 48 (SIMPLE_EDGE), Reducer 21 (SIMPLE_EDGE) +Reducer 23 <- Map 15 (SIMPLE_EDGE), Reducer 38 (SIMPLE_EDGE) +Reducer 24 <- Reducer 23 (SIMPLE_EDGE), Reducer 45 (ONE_TO_ONE_EDGE) +Reducer 25 <- Map 46 (SIMPLE_EDGE), Reducer 24 (SIMPLE_EDGE) +Reducer 26 <- Reducer 25 (SIMPLE_EDGE), Reducer 31 (SIMPLE_EDGE) +Reducer 27 <- Map 47 (SIMPLE_EDGE), Reducer 26 (SIMPLE_EDGE) +Reducer 28 <- Map 33 (SIMPLE_EDGE), Reducer 27 (SIMPLE_EDGE) +Reducer 29 <- Map 48 (SIMPLE_EDGE), Reducer 28 (SIMPLE_EDGE) +Reducer 3 <- Map 15 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE) +Reducer 31 <- Map 30 (SIMPLE_EDGE), Map 32 (SIMPLE_EDGE) +Reducer 35 <- Map 34 (SIMPLE_EDGE), Map 36 (SIMPLE_EDGE) +Reducer 37 <- Map 36 (CUSTOM_SIMPLE_EDGE) +Reducer 38 <- Map 36 (SIMPLE_EDGE), Map 50 (SIMPLE_EDGE) +Reducer 39 <- Map 36 (CUSTOM_SIMPLE_EDGE) +Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 31 (SIMPLE_EDGE) +Reducer 41 <- Map 40 (SIMPLE_EDGE), Map 43 (SIMPLE_EDGE) +Reducer 42 <- Reducer 41 (SIMPLE_EDGE) +Reducer 44 <- Map 43 (SIMPLE_EDGE), Map 51 (SIMPLE_EDGE) Reducer 45 <- Reducer 44 (SIMPLE_EDGE) -Reducer 46 <- Reducer 45 (CUSTOM_SIMPLE_EDGE) -Reducer 48 <- Map 47 (SIMPLE_EDGE), Map 56 (SIMPLE_EDGE) -Reducer 49 <- Reducer 48 (SIMPLE_EDGE) -Reducer 5 <- Map 36 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE) -Reducer 50 <- Reducer 49 (CUSTOM_SIMPLE_EDGE) -Reducer 6 <- Map 54 (SIMPLE_EDGE), Reducer 5 (SIMPLE_EDGE) -Reducer 7 <- Reducer 23 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE) -Reducer 8 <- Map 54 (SIMPLE_EDGE), Reducer 7 (SIMPLE_EDGE) +Reducer 5 <- Map 33 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE) +Reducer 6 <- Map 49 (SIMPLE_EDGE), Reducer 5 (SIMPLE_EDGE) +Reducer 7 <- Reducer 22 (SIMPLE_EDGE), Reducer 6 (SIMPLE_EDGE) +Reducer 8 <- Map 49 (SIMPLE_EDGE), Reducer 7 (SIMPLE_EDGE) Reducer 9 <- Reducer 8 (SIMPLE_EDGE) Stage-0 @@ -316,8 +311,8 @@ Stage-0 limit:-1 Stage-1 Reducer 11 vectorized - File Output Operator [FS_1201] - Select Operator [SEL_1200] (rows=2169965329 width=1702) + File Output Operator [FS_1176] + Select Operator [SEL_1175] (rows=2169965329 width=1702) 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_257] @@ -326,59 +321,59 @@ Stage-0 Filter Operator [FIL_255] (rows=2169965329 width=1694) predicate:(_col19 <= _col12) Merge Join Operator [MERGEJOIN_1087] (rows=6509895988 width=1694) - Conds:RS_1171._col2, _col1, _col3=RS_1199._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 9 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1171] - PartitionCols:_col2, _col1, _col3 - Select Operator [SEL_1170] (rows=2299138 width=1354) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15"] - Group By Operator [GBY_1169] (rows=2299138 width=1362) + Conds:RS_1158._col2, _col1, _col3=RS_1174._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_1174] + PartitionCols:_col1, _col0, _col2 + Select Operator [SEL_1173] (rows=2299138 width=525) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"] + Group By Operator [GBY_1172] (rows=2299138 width=1362) 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 8 [SIMPLE_EDGE] - SHUFFLE [RS_123] + <-Reducer 13 [SIMPLE_EDGE] + SHUFFLE [RS_249] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, _col11, _col12, _col13 - Group By Operator [GBY_122] (rows=2299138 width=1362) + Group By Operator [GBY_248] (rows=2299138 width=1362) 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, _col47 - Select Operator [SEL_121] (rows=2331650 width=1292) + Select Operator [SEL_247] (rows=2331650 width=1292) Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col47"] - Filter Operator [FIL_120] (rows=2331650 width=1292) + Filter Operator [FIL_246] (rows=2331650 width=1292) predicate:(_col51 <> _col19) - Merge Join Operator [MERGEJOIN_1068] (rows=2331650 width=1292) - Conds:RS_117._col37=RS_1120._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col47","_col51"] - <-Map 54 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1120] + Merge Join Operator [MERGEJOIN_1086] (rows=2331650 width=1292) + Conds:RS_243._col37=RS_1116._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col47","_col51"] + <-Map 49 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1116] PartitionCols:_col0 - Select Operator [SEL_1119] (rows=1861800 width=89) + Select Operator [SEL_1113] (rows=1861800 width=89) Output:["_col0","_col1"] - Filter Operator [FIL_1118] (rows=1861800 width=89) + Filter Operator [FIL_1112] (rows=1861800 width=89) predicate:cd_demo_sk is not null TableScan [TS_96] (rows=1861800 width=89) default@customer_demographics,cd1,Tbl:COMPLETE,Col:COMPLETE,Output:["cd_demo_sk","cd_marital_status"] - <-Reducer 7 [SIMPLE_EDGE] - SHUFFLE [RS_117] + <-Reducer 12 [SIMPLE_EDGE] + SHUFFLE [RS_243] PartitionCols:_col37 - Merge Join Operator [MERGEJOIN_1067] (rows=2299138 width=1205) - Conds:RS_114._col0=RS_115._col16(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col37","_col43","_col44","_col45","_col46","_col47"] + Merge Join Operator [MERGEJOIN_1085] (rows=2299138 width=1205) + Conds:RS_240._col0=RS_241._col16(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col37","_col43","_col44","_col45","_col46","_col47"] <-Reducer 6 [SIMPLE_EDGE] - SHUFFLE [RS_114] + SHUFFLE [RS_240] PartitionCols:_col0 Merge Join Operator [MERGEJOIN_1056] (rows=70357394 width=458) - Conds:RS_111._col1=RS_1121._col0(Inner),Output:["_col0","_col7","_col9","_col14","_col15","_col16","_col17","_col19"] - <-Map 54 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1121] + Conds:RS_111._col1=RS_1115._col0(Inner),Output:["_col0","_col7","_col9","_col14","_col15","_col16","_col17","_col19"] + <-Map 49 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1115] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1119] + Please refer to the previous Select Operator [SEL_1113] <-Reducer 5 [SIMPLE_EDGE] SHUFFLE [RS_111] PartitionCols:_col1 Merge Join Operator [MERGEJOIN_1055] (rows=69376329 width=376) - Conds:RS_108._col3=RS_1115._col0(Inner),Output:["_col0","_col1","_col7","_col9","_col14","_col15","_col16","_col17"] - <-Map 36 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1115] + Conds:RS_108._col3=RS_1109._col0(Inner),Output:["_col0","_col1","_col7","_col9","_col14","_col15","_col16","_col17"] + <-Map 33 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1109] PartitionCols:_col0 - Select Operator [SEL_1114] (rows=40000000 width=365) + Select Operator [SEL_1108] (rows=40000000 width=365) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_1113] (rows=40000000 width=365) + Filter Operator [FIL_1107] (rows=40000000 width=365) predicate:ca_address_sk is not null TableScan [TS_19] (rows=40000000 width=365) default@customer_address,ad2,Tbl:COMPLETE,Col:COMPLETE,Output:["ca_address_sk","ca_street_number","ca_street_name","ca_city","ca_zip"] @@ -387,26 +382,26 @@ Stage-0 PartitionCols:_col3 Merge Join Operator [MERGEJOIN_1054] (rows=69376329 width=19) Conds:RS_105._col2=RS_106._col0(Inner),Output:["_col0","_col1","_col3","_col7","_col9"] - <-Reducer 34 [SIMPLE_EDGE] + <-Reducer 31 [SIMPLE_EDGE] SHUFFLE [RS_106] PartitionCols:_col0 Merge Join Operator [MERGEJOIN_1053] (rows=7200 width=4) - Conds:RS_1109._col1=RS_1112._col0(Inner),Output:["_col0"] - <-Map 33 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1109] + Conds:RS_1103._col1=RS_1106._col0(Inner),Output:["_col0"] + <-Map 30 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1103] PartitionCols:_col1 - Select Operator [SEL_1108] (rows=7200 width=8) + Select Operator [SEL_1102] (rows=7200 width=8) Output:["_col0","_col1"] - Filter Operator [FIL_1107] (rows=7200 width=8) + Filter Operator [FIL_1101] (rows=7200 width=8) predicate:(hd_demo_sk is not null and hd_income_band_sk is not null) TableScan [TS_9] (rows=7200 width=8) default@household_demographics,hd2,Tbl:COMPLETE,Col:COMPLETE,Output:["hd_demo_sk","hd_income_band_sk"] - <-Map 35 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1112] + <-Map 32 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1106] PartitionCols:_col0 - Select Operator [SEL_1111] (rows=20 width=4) + Select Operator [SEL_1105] (rows=20 width=4) Output:["_col0"] - Filter Operator [FIL_1110] (rows=20 width=4) + Filter Operator [FIL_1104] (rows=20 width=4) predicate:ib_income_band_sk is not null TableScan [TS_12] (rows=20 width=4) default@income_band,ib2,Tbl:COMPLETE,Col:COMPLETE,Output:["ib_income_band_sk"] @@ -415,8 +410,8 @@ Stage-0 PartitionCols:_col2 Merge Join Operator [MERGEJOIN_1052] (rows=69376329 width=23) Conds:RS_102._col4=RS_1098._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col7","_col9"] - <-Map 16 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1098] + <-Map 15 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1098] PartitionCols:_col0 Select Operator [SEL_1094] (rows=73049 width=8) Output:["_col0","_col1"] @@ -429,8 +424,8 @@ Stage-0 PartitionCols:_col4 Merge Join Operator [MERGEJOIN_1051] (rows=69376329 width=23) Conds:RS_1090._col5=RS_1097._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col7"] - <-Map 16 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1097] + <-Map 15 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1097] PartitionCols:_col0 Please refer to the previous Select Operator [SEL_1094] <-Map 1 [SIMPLE_EDGE] vectorized @@ -442,371 +437,316 @@ Stage-0 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=23) default@customer,customer,Tbl:COMPLETE,Col:COMPLETE,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 23 [SIMPLE_EDGE] - SHUFFLE [RS_115] + <-Reducer 29 [SIMPLE_EDGE] + SHUFFLE [RS_241] PartitionCols:_col16 - Select Operator [SEL_95] (rows=2651207 width=784) + Select Operator [SEL_221] (rows=2651207 width=784) Output:["_col3","_col4","_col5","_col6","_col8","_col9","_col16","_col17","_col23","_col24","_col25","_col26","_col27"] - Merge Join Operator [MERGEJOIN_1066] (rows=2651207 width=784) - Conds:RS_92._col5, _col12=RS_1167._col0, _col1(Inner),Output:["_col6","_col7","_col13","_col14","_col15","_col16","_col17","_col21","_col22","_col24","_col25","_col26","_col27"] - <-Map 53 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1167] + Merge Join Operator [MERGEJOIN_1084] (rows=2651207 width=784) + Conds:RS_218._col5, _col12=RS_1155._col0, _col1(Inner),Output:["_col6","_col7","_col13","_col14","_col15","_col16","_col17","_col21","_col22","_col24","_col25","_col26","_col27"] + <-Map 48 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1155] PartitionCols:_col0, _col1 - Select Operator [SEL_1166] (rows=57591150 width=8) + Select Operator [SEL_1153] (rows=57591150 width=8) Output:["_col0","_col1"] - Filter Operator [FIL_1165] (rows=57591150 width=8) + Filter Operator [FIL_1152] (rows=57591150 width=8) predicate:(sr_item_sk is not null and sr_ticket_number is not null) TableScan [TS_77] (rows=57591150 width=8) default@store_returns,store_returns,Tbl:COMPLETE,Col:COMPLETE,Output:["sr_item_sk","sr_ticket_number"] - <-Reducer 22 [SIMPLE_EDGE] - SHUFFLE [RS_92] + <-Reducer 28 [SIMPLE_EDGE] + SHUFFLE [RS_218] PartitionCols:_col5, _col12 - Merge Join Operator [MERGEJOIN_1065] (rows=1608052 width=657) - Conds:RS_89._col9=RS_1116._col0(Inner),Output:["_col5","_col6","_col7","_col12","_col13","_col14","_col15","_col16","_col17","_col21","_col22","_col24","_col25","_col26","_col27"] - <-Map 36 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1116] + Merge Join Operator [MERGEJOIN_1083] (rows=1608052 width=657) + Conds:RS_215._col9=RS_1111._col0(Inner),Output:["_col5","_col6","_col7","_col12","_col13","_col14","_col15","_col16","_col17","_col21","_col22","_col24","_col25","_col26","_col27"] + <-Map 33 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1111] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1114] - <-Reducer 21 [SIMPLE_EDGE] - SHUFFLE [RS_89] + Please refer to the previous Select Operator [SEL_1108] + <-Reducer 27 [SIMPLE_EDGE] + SHUFFLE [RS_215] PartitionCols:_col9 - Merge Join Operator [MERGEJOIN_1064] (rows=1608052 width=296) - Conds:RS_86._col10=RS_1163._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col12","_col13","_col14","_col15","_col16","_col17","_col21","_col22"] - <-Map 52 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1163] + Merge Join Operator [MERGEJOIN_1082] (rows=1608052 width=296) + Conds:RS_212._col10=RS_1151._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col12","_col13","_col14","_col15","_col16","_col17","_col21","_col22"] + <-Map 47 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1151] PartitionCols:_col0 - Select Operator [SEL_1162] (rows=1704 width=181) + Select Operator [SEL_1149] (rows=1704 width=181) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1161] (rows=1704 width=181) + Filter Operator [FIL_1148] (rows=1704 width=181) predicate:(s_store_name is not null and s_store_sk is not null and s_zip is not null) TableScan [TS_71] (rows=1704 width=181) default@store,store,Tbl:COMPLETE,Col:COMPLETE,Output:["s_store_sk","s_store_name","s_zip"] - <-Reducer 20 [SIMPLE_EDGE] - SHUFFLE [RS_86] + <-Reducer 26 [SIMPLE_EDGE] + SHUFFLE [RS_212] PartitionCols:_col10 - Merge Join Operator [MERGEJOIN_1063] (rows=1608052 width=119) - Conds:RS_83._col0=RS_84._col5(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col17"] - <-Reducer 34 [SIMPLE_EDGE] - SHUFFLE [RS_83] + Merge Join Operator [MERGEJOIN_1081] (rows=1608052 width=119) + Conds:RS_209._col0=RS_210._col5(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col17"] + <-Reducer 31 [SIMPLE_EDGE] + SHUFFLE [RS_209] PartitionCols:_col0 Please refer to the previous Merge Join Operator [MERGEJOIN_1053] - <-Reducer 19 [SIMPLE_EDGE] - SHUFFLE [RS_84] + <-Reducer 25 [SIMPLE_EDGE] + SHUFFLE [RS_210] PartitionCols:_col5 - Select Operator [SEL_70] (rows=1608052 width=119) + Select Operator [SEL_196] (rows=1608052 width=119) Output:["_col2","_col3","_col4","_col5","_col6","_col7","_col9","_col10","_col11","_col12","_col13","_col14"] - Merge Join Operator [MERGEJOIN_1062] (rows=1608052 width=119) - Conds:RS_67._col7=RS_1159._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col8","_col9","_col10","_col11","_col12","_col13"] - <-Map 51 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1159] + Merge Join Operator [MERGEJOIN_1080] (rows=1608052 width=119) + Conds:RS_193._col7=RS_1147._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col8","_col9","_col10","_col11","_col12","_col13"] + <-Map 46 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1147] PartitionCols:_col0 - Select Operator [SEL_1158] (rows=2300 width=4) + Select Operator [SEL_1145] (rows=2300 width=4) Output:["_col0"] - Filter Operator [FIL_1157] (rows=2300 width=4) + Filter Operator [FIL_1144] (rows=2300 width=4) predicate:p_promo_sk is not null TableScan [TS_55] (rows=2300 width=4) default@promotion,promotion,Tbl:COMPLETE,Col:COMPLETE,Output:["p_promo_sk"] - <-Reducer 18 [SIMPLE_EDGE] - SHUFFLE [RS_67] + <-Reducer 24 [SIMPLE_EDGE] + SHUFFLE [RS_193] PartitionCols:_col7 - Merge Join Operator [MERGEJOIN_1061] (rows=1608052 width=119) - Conds:RS_64._col1=RS_1148._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] + Merge Join Operator [MERGEJOIN_1079] (rows=1608052 width=119) + Conds:RS_190._col1=RS_1171._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] + <-Reducer 23 [SIMPLE_EDGE] + SHUFFLE [RS_190] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_1077] (rows=1608052 width=119) + Conds:RS_187._col0=RS_1100._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] + <-Map 15 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1100] + PartitionCols:_col0 + Select Operator [SEL_1096] (rows=652 width=4) + Output:["_col0"] + Filter Operator [FIL_1093] (rows=652 width=8) + predicate:((d_year = 2001) and d_date_sk is not null) + Please refer to the previous TableScan [TS_3] + <-Reducer 38 [SIMPLE_EDGE] + SHUFFLE [RS_187] + PartitionCols:_col0 + Merge Join Operator [MERGEJOIN_1076] (rows=4503592 width=119) + Conds:RS_1164._col1=RS_1121._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] + <-Map 36 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1121] + PartitionCols:_col0 + Select Operator [SEL_1118] (rows=518 width=111) + Output:["_col0","_col1"] + Filter Operator [FIL_1117] (rows=518 width=312) + 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=311) + default@item,item,Tbl:COMPLETE,Col:COMPLETE,Output:["i_item_sk","i_current_price","i_color","i_product_name"] + <-Map 50 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1164] + PartitionCols:_col1 + Select Operator [SEL_1163] (rows=417313408 width=355) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] + Filter Operator [FIL_1162] (rows=417313408 width=355) + predicate:((ss_item_sk BETWEEN DynamicValue(RS_185_item_i_item_sk_min) AND DynamicValue(RS_185_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_185_item_i_item_sk_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_157] (rows=575995635 width=355) + default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,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 39 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1160] + Group By Operator [GBY_1159] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 36 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1126] + Group By Operator [GBY_1124] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_1122] (rows=518 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_1118] <-Reducer 45 [ONE_TO_ONE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1148] + FORWARD [RS_1171] PartitionCols:_col0 - Select Operator [SEL_1147] (rows=13257 width=4) + Select Operator [SEL_1170] (rows=13257 width=4) Output:["_col0"] - Filter Operator [FIL_1146] (rows=13257 width=228) + Filter Operator [FIL_1169] (rows=13257 width=228) predicate:(_col1 > (2 * _col2)) - Group By Operator [GBY_1145] (rows=39773 width=228) + Group By Operator [GBY_1168] (rows=39773 width=228) Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0 <-Reducer 44 [SIMPLE_EDGE] - SHUFFLE [RS_51] + SHUFFLE [RS_177] PartitionCols:_col0 - Group By Operator [GBY_50] (rows=6482999 width=228) + Group By Operator [GBY_176] (rows=6482999 width=228) Output:["_col0","_col1","_col2"],aggregations:["sum(_col2)","sum(_col5)"],keys:_col0 - Merge Join Operator [MERGEJOIN_1060] (rows=183085709 width=227) - Conds:RS_1140._col0, _col1=RS_1143._col0, _col1(Inner),Output:["_col0","_col2","_col5"] - <-Map 47 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1143] + Merge Join Operator [MERGEJOIN_1078] (rows=183085709 width=227) + Conds:RS_1167._col0, _col1=RS_1139._col0, _col1(Inner),Output:["_col0","_col2","_col5"] + <-Map 43 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1139] PartitionCols:_col0, _col1 - Select Operator [SEL_1142] (rows=28798881 width=120) + Select Operator [SEL_1137] (rows=28798881 width=120) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1141] (rows=28798881 width=337) + Filter Operator [FIL_1136] (rows=28798881 width=337) predicate:(cr_item_sk is not null and cr_order_number is not null) TableScan [TS_43] (rows=28798881 width=337) default@catalog_returns,catalog_returns,Tbl:COMPLETE,Col:COMPLETE,Output:["cr_item_sk","cr_order_number","cr_refunded_cash","cr_reversed_charge","cr_store_credit"] - <-Map 43 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1140] + <-Map 51 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1167] PartitionCols:_col0, _col1 - Select Operator [SEL_1139] (rows=287989836 width=119) + Select Operator [SEL_1166] (rows=287989836 width=119) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1138] (rows=287989836 width=119) - predicate:((cs_item_sk BETWEEN DynamicValue(RS_59_item_i_item_sk_min) AND DynamicValue(RS_59_item_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_59_item_i_item_sk_bloom_filter))) and cs_item_sk is not null and cs_order_number is not null) - TableScan [TS_40] (rows=287989836 width=119) + Filter Operator [FIL_1165] (rows=287989836 width=119) + predicate:((cs_item_sk BETWEEN DynamicValue(RS_185_item_i_item_sk_min) AND DynamicValue(RS_185_item_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_185_item_i_item_sk_bloom_filter))) and cs_item_sk is not null and cs_order_number is not null) + TableScan [TS_166] (rows=287989836 width=119) default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["cs_item_sk","cs_order_number","cs_ext_list_price"] - <-Reducer 40 [BROADCAST_EDGE] vectorized - BROADCAST [RS_1135] - Group By Operator [GBY_1133] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 39 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1131] - Group By Operator [GBY_1129] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_1126] (rows=518 width=4) - Output:["_col0"] - Select Operator [SEL_1124] (rows=518 width=111) - Output:["_col0","_col1"] - Filter Operator [FIL_1123] (rows=518 width=312) - 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=311) - default@item,item,Tbl:COMPLETE,Col:COMPLETE,Output:["i_item_sk","i_current_price","i_color","i_product_name"] - <-Reducer 17 [SIMPLE_EDGE] - SHUFFLE [RS_64] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_1059] (rows=1608052 width=119) - Conds:RS_61._col0=RS_1099._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] - <-Map 16 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1099] - PartitionCols:_col0 - Select Operator [SEL_1095] (rows=652 width=4) - Output:["_col0"] - Filter Operator [FIL_1092] (rows=652 width=8) - predicate:((d_year = 2000) and d_date_sk is not null) - Please refer to the previous TableScan [TS_3] - <-Reducer 38 [SIMPLE_EDGE] - SHUFFLE [RS_61] - PartitionCols:_col0 - Merge Join Operator [MERGEJOIN_1058] (rows=4503592 width=119) - Conds:RS_1156._col1=RS_1125._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] - <-Map 39 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1125] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1124] - <-Map 37 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1156] - PartitionCols:_col1 - Select Operator [SEL_1155] (rows=417313408 width=355) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] - Filter Operator [FIL_1154] (rows=417313408 width=355) - predicate:((ss_item_sk BETWEEN DynamicValue(RS_59_item_i_item_sk_min) AND DynamicValue(RS_59_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_59_item_i_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_65_catalog_sales_cs_item_sk_min) AND DynamicValue(RS_65_catalog_sales_cs_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_65_catalog_sales_cs_item_sk_bloom_filter))) and (ss_sold_date_sk BETWEEN DynamicValue(RS_62_d1_d_date_sk_min) AND DynamicValue(RS_62_d1_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_62_d1_d_date_sk_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_31] (rows=575995635 width=355) - default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,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 40 [BROADCAST_EDGE] vectorized - BROADCAST [RS_1134] - Please refer to the previous Group By Operator [GBY_1133] - <-Reducer 24 [BROADCAST_EDGE] vectorized - BROADCAST [RS_1137] - Group By Operator [GBY_1136] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 16 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1105] - Group By Operator [GBY_1103] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_1100] (rows=652 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_1095] - <-Reducer 46 [BROADCAST_EDGE] vectorized - BROADCAST [RS_1153] - Group By Operator [GBY_1152] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Reducer 45 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1151] - Group By Operator [GBY_1150] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_1149] (rows=13257 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_1147] - <-Reducer 15 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1199] - PartitionCols:_col1, _col0, _col2 - Select Operator [SEL_1198] (rows=2299138 width=525) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"] - Group By Operator [GBY_1197] (rows=2299138 width=1362) + <-Reducer 39 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1161] + Please refer to the previous Group By Operator [GBY_1159] + <-Reducer 9 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1158] + PartitionCols:_col2, _col1, _col3 + Select Operator [SEL_1157] (rows=2299138 width=1354) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14","_col15"] + Group By Operator [GBY_1156] (rows=2299138 width=1362) 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 14 [SIMPLE_EDGE] - SHUFFLE [RS_249] + <-Reducer 8 [SIMPLE_EDGE] + SHUFFLE [RS_123] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, _col11, _col12, _col13 - Group By Operator [GBY_248] (rows=2299138 width=1362) + Group By Operator [GBY_122] (rows=2299138 width=1362) 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, _col47 - Select Operator [SEL_247] (rows=2331650 width=1292) + Select Operator [SEL_121] (rows=2331650 width=1292) Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col47"] - Filter Operator [FIL_246] (rows=2331650 width=1292) + Filter Operator [FIL_120] (rows=2331650 width=1292) predicate:(_col51 <> _col19) - Merge Join Operator [MERGEJOIN_1086] (rows=2331650 width=1292) - Conds:RS_243._col37=RS_1122._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col47","_col51"] - <-Map 54 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1122] + Merge Join Operator [MERGEJOIN_1068] (rows=2331650 width=1292) + Conds:RS_117._col37=RS_1114._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col47","_col51"] + <-Map 49 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1114] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1119] - <-Reducer 13 [SIMPLE_EDGE] - SHUFFLE [RS_243] + Please refer to the previous Select Operator [SEL_1113] + <-Reducer 7 [SIMPLE_EDGE] + SHUFFLE [RS_117] PartitionCols:_col37 - Merge Join Operator [MERGEJOIN_1085] (rows=2299138 width=1205) - Conds:RS_240._col0=RS_241._col16(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col37","_col43","_col44","_col45","_col46","_col47"] + Merge Join Operator [MERGEJOIN_1067] (rows=2299138 width=1205) + Conds:RS_114._col0=RS_115._col16(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col37","_col43","_col44","_col45","_col46","_col47"] <-Reducer 6 [SIMPLE_EDGE] - SHUFFLE [RS_240] + SHUFFLE [RS_114] PartitionCols:_col0 Please refer to the previous Merge Join Operator [MERGEJOIN_1056] - <-Reducer 31 [SIMPLE_EDGE] - SHUFFLE [RS_241] + <-Reducer 22 [SIMPLE_EDGE] + SHUFFLE [RS_115] PartitionCols:_col16 - Select Operator [SEL_221] (rows=2651207 width=784) + Select Operator [SEL_95] (rows=2651207 width=784) Output:["_col3","_col4","_col5","_col6","_col8","_col9","_col16","_col17","_col23","_col24","_col25","_col26","_col27"] - Merge Join Operator [MERGEJOIN_1084] (rows=2651207 width=784) - Conds:RS_218._col5, _col12=RS_1168._col0, _col1(Inner),Output:["_col6","_col7","_col13","_col14","_col15","_col16","_col17","_col21","_col22","_col24","_col25","_col26","_col27"] - <-Map 53 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1168] + Merge Join Operator [MERGEJOIN_1066] (rows=2651207 width=784) + Conds:RS_92._col5, _col12=RS_1154._col0, _col1(Inner),Output:["_col6","_col7","_col13","_col14","_col15","_col16","_col17","_col21","_col22","_col24","_col25","_col26","_col27"] + <-Map 48 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1154] PartitionCols:_col0, _col1 - Please refer to the previous Select Operator [SEL_1166] - <-Reducer 30 [SIMPLE_EDGE] - SHUFFLE [RS_218] + Please refer to the previous Select Operator [SEL_1153] + <-Reducer 21 [SIMPLE_EDGE] + SHUFFLE [RS_92] PartitionCols:_col5, _col12 - Merge Join Operator [MERGEJOIN_1083] (rows=1608052 width=657) - Conds:RS_215._col9=RS_1117._col0(Inner),Output:["_col5","_col6","_col7","_col12","_col13","_col14","_col15","_col16","_col17","_col21","_col22","_col24","_col25","_col26","_col27"] - <-Map 36 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1117] + Merge Join Operator [MERGEJOIN_1065] (rows=1608052 width=657) + Conds:RS_89._col9=RS_1110._col0(Inner),Output:["_col5","_col6","_col7","_col12","_col13","_col14","_col15","_col16","_col17","_col21","_col22","_col24","_col25","_col26","_col27"] + <-Map 33 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1110] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1114] - <-Reducer 29 [SIMPLE_EDGE] - SHUFFLE [RS_215] + Please refer to the previous Select Operator [SEL_1108] + <-Reducer 20 [SIMPLE_EDGE] + SHUFFLE [RS_89] PartitionCols:_col9 - Merge Join Operator [MERGEJOIN_1082] (rows=1608052 width=296) - Conds:RS_212._col10=RS_1164._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col12","_col13","_col14","_col15","_col16","_col17","_col21","_col22"] - <-Map 52 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1164] + Merge Join Operator [MERGEJOIN_1064] (rows=1608052 width=296) + Conds:RS_86._col10=RS_1150._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col12","_col13","_col14","_col15","_col16","_col17","_col21","_col22"] + <-Map 47 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1150] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1162] - <-Reducer 28 [SIMPLE_EDGE] - SHUFFLE [RS_212] + Please refer to the previous Select Operator [SEL_1149] + <-Reducer 19 [SIMPLE_EDGE] + SHUFFLE [RS_86] PartitionCols:_col10 - Merge Join Operator [MERGEJOIN_1081] (rows=1608052 width=119) - Conds:RS_209._col0=RS_210._col5(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col17"] - <-Reducer 34 [SIMPLE_EDGE] - SHUFFLE [RS_209] + Merge Join Operator [MERGEJOIN_1063] (rows=1608052 width=119) + Conds:RS_83._col0=RS_84._col5(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col17"] + <-Reducer 31 [SIMPLE_EDGE] + SHUFFLE [RS_83] PartitionCols:_col0 Please refer to the previous Merge Join Operator [MERGEJOIN_1053] - <-Reducer 27 [SIMPLE_EDGE] - SHUFFLE [RS_210] + <-Reducer 18 [SIMPLE_EDGE] + SHUFFLE [RS_84] PartitionCols:_col5 - Select Operator [SEL_196] (rows=1608052 width=119) + Select Operator [SEL_70] (rows=1608052 width=119) Output:["_col2","_col3","_col4","_col5","_col6","_col7","_col9","_col10","_col11","_col12","_col13","_col14"] - Merge Join Operator [MERGEJOIN_1080] (rows=1608052 width=119) - Conds:RS_193._col7=RS_1160._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col8","_col9","_col10","_col11","_col12","_col13"] - <-Map 51 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1160] + Merge Join Operator [MERGEJOIN_1062] (rows=1608052 width=119) + Conds:RS_67._col7=RS_1146._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col8","_col9","_col10","_col11","_col12","_col13"] + <-Map 46 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1146] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1158] - <-Reducer 26 [SIMPLE_EDGE] - SHUFFLE [RS_193] + Please refer to the previous Select Operator [SEL_1145] + <-Reducer 17 [SIMPLE_EDGE] + SHUFFLE [RS_67] PartitionCols:_col7 - Merge Join Operator [MERGEJOIN_1079] (rows=1608052 width=119) - Conds:RS_190._col1=RS_1186._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] - <-Reducer 49 [ONE_TO_ONE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1186] - PartitionCols:_col0 - Select Operator [SEL_1185] (rows=13257 width=4) - Output:["_col0"] - Filter Operator [FIL_1184] (rows=13257 width=228) - predicate:(_col1 > (2 * _col2)) - Group By Operator [GBY_1183] (rows=39773 width=228) - Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0 - <-Reducer 48 [SIMPLE_EDGE] - SHUFFLE [RS_177] - PartitionCols:_col0 - Group By Operator [GBY_176] (rows=6482999 width=228) - Output:["_col0","_col1","_col2"],aggregations:["sum(_col2)","sum(_col5)"],keys:_col0 - Merge Join Operator [MERGEJOIN_1078] (rows=183085709 width=227) - Conds:RS_1182._col0, _col1=RS_1144._col0, _col1(Inner),Output:["_col0","_col2","_col5"] - <-Map 47 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1144] - PartitionCols:_col0, _col1 - Please refer to the previous Select Operator [SEL_1142] - <-Map 56 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1182] - PartitionCols:_col0, _col1 - Select Operator [SEL_1181] (rows=287989836 width=119) - Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1180] (rows=287989836 width=119) - predicate:((cs_item_sk BETWEEN DynamicValue(RS_185_item_i_item_sk_min) AND DynamicValue(RS_185_item_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_185_item_i_item_sk_bloom_filter))) and cs_item_sk is not null and cs_order_number is not null) - TableScan [TS_166] (rows=287989836 width=119) - default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["cs_item_sk","cs_order_number","cs_ext_list_price"] - <-Reducer 42 [BROADCAST_EDGE] vectorized - BROADCAST [RS_1177] - Group By Operator [GBY_1175] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 39 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1132] - Group By Operator [GBY_1130] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_1128] (rows=518 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_1124] - <-Reducer 25 [SIMPLE_EDGE] - SHUFFLE [RS_190] + Merge Join Operator [MERGEJOIN_1061] (rows=1608052 width=119) + Conds:RS_64._col1=RS_1143._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] + <-Reducer 16 [SIMPLE_EDGE] + SHUFFLE [RS_64] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_1077] (rows=1608052 width=119) - Conds:RS_187._col0=RS_1101._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] - <-Map 16 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1101] + Merge Join Operator [MERGEJOIN_1059] (rows=1608052 width=119) + Conds:RS_61._col0=RS_1099._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] + <-Map 15 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1099] PartitionCols:_col0 - Select Operator [SEL_1096] (rows=652 width=4) + Select Operator [SEL_1095] (rows=652 width=4) Output:["_col0"] - Filter Operator [FIL_1093] (rows=652 width=8) - predicate:((d_year = 2001) and d_date_sk is not null) + Filter Operator [FIL_1092] (rows=652 width=8) + predicate:((d_year = 2000) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] - <-Reducer 41 [SIMPLE_EDGE] - SHUFFLE [RS_187] + <-Reducer 35 [SIMPLE_EDGE] + SHUFFLE [RS_61] PartitionCols:_col0 - Merge Join Operator [MERGEJOIN_1076] (rows=4503592 width=119) - Conds:RS_1196._col1=RS_1127._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] - <-Map 39 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1127] + Merge Join Operator [MERGEJOIN_1058] (rows=4503592 width=119) + Conds:RS_1132._col1=RS_1119._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13"] + <-Map 36 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1119] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_1124] - <-Map 55 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1196] + Please refer to the previous Select Operator [SEL_1118] + <-Map 34 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_1132] PartitionCols:_col1 - Select Operator [SEL_1195] (rows=417313408 width=355) + Select Operator [SEL_1131] (rows=417313408 width=355) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] - Filter Operator [FIL_1194] (rows=417313408 width=355) - predicate:((ss_item_sk BETWEEN DynamicValue(RS_185_item_i_item_sk_min) AND DynamicValue(RS_185_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_185_item_i_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_191_catalog_sales_cs_item_sk_min) AND DynamicValue(RS_191_catalog_sales_cs_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_191_catalog_sales_cs_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_252_item_i_item_sk_min) AND DynamicValue(RS_252_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_252_item_i_item_sk_bloom_filter))) and (ss_sold_date_sk BETWEEN DynamicValue(RS_188_d1_d_date_sk_min) AND DynamicValue(RS_188_d1_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_188_d1_d_date_sk_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 nul l 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_157] (rows=575995635 width=355) + Filter Operator [FIL_1130] (rows=417313408 width=355) + predicate:((ss_item_sk BETWEEN DynamicValue(RS_59_item_i_item_sk_min) AND DynamicValue(RS_59_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_59_item_i_item_sk_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_31] (rows=575995635 width=355) default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,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_1176] - Please refer to the previous Group By Operator [GBY_1175] - <-Reducer 12 [BROADCAST_EDGE] vectorized - BROADCAST [RS_1193] - Group By Operator [GBY_1192] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Reducer 9 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1174] - Group By Operator [GBY_1173] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_1172] (rows=2299138 width=8) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_1170] - <-Reducer 32 [BROADCAST_EDGE] vectorized - BROADCAST [RS_1179] - Group By Operator [GBY_1178] (rows=1 width=12) + <-Reducer 37 [BROADCAST_EDGE] vectorized + BROADCAST [RS_1128] + Group By Operator [GBY_1127] (rows=1 width=12) O
<TRUNCATED>
