http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/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 f670c4f..7c77e9f 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query64.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query64.q.out @@ -265,9 +265,9 @@ 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 47 (BROADCAST_EDGE) -Map 44 <- Reducer 40 (BROADCAST_EDGE) -Map 55 <- Reducer 12 (BROADCAST_EDGE), Reducer 32 (BROADCAST_EDGE), Reducer 42 (BROADCAST_EDGE), Reducer 51 (BROADCAST_EDGE) +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) Reducer 11 <- Reducer 10 (SIMPLE_EDGE) @@ -276,18 +276,18 @@ 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 <- Map 43 (SIMPLE_EDGE), Reducer 17 (SIMPLE_EDGE) -Reducer 19 <- Reducer 18 (SIMPLE_EDGE), Reducer 34 (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 46 (ONE_TO_ONE_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 <- Map 43 (SIMPLE_EDGE), Reducer 25 (SIMPLE_EDGE) -Reducer 27 <- Reducer 26 (SIMPLE_EDGE), Reducer 34 (SIMPLE_EDGE) -Reducer 28 <- Reducer 27 (SIMPLE_EDGE), Reducer 50 (ONE_TO_ONE_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) @@ -299,13 +299,13 @@ 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 45 <- Map 44 (SIMPLE_EDGE), Map 48 (SIMPLE_EDGE) -Reducer 46 <- Reducer 45 (SIMPLE_EDGE) -Reducer 47 <- Reducer 46 (CUSTOM_SIMPLE_EDGE) -Reducer 49 <- Map 48 (SIMPLE_EDGE), Map 56 (SIMPLE_EDGE) +Reducer 44 <- Map 43 (SIMPLE_EDGE), Map 47 (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 (SIMPLE_EDGE) -Reducer 51 <- Reducer 50 (CUSTOM_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) @@ -320,10 +320,10 @@ Stage-0 Select Operator [SEL_1200] (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_259] - Select Operator [SEL_258] (rows=2169965329 width=1694) + SHUFFLE [RS_257] + Select Operator [SEL_256] (rows=2169965329 width=1694) 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=2169965329 width=1694) + 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"] @@ -335,16 +335,16 @@ Stage-0 Group By Operator [GBY_1169] (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_124] + SHUFFLE [RS_123] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, _col11, _col12, _col13 - Group By Operator [GBY_123] (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, _col49 - Select Operator [SEL_122] (rows=2331650 width=1292) - Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col49"] - Filter Operator [FIL_121] (rows=2331650 width=1292) - predicate:(_col56 <> _col19) + 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_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_120] (rows=2331650 width=1292) + predicate:(_col51 <> _col19) Merge Join Operator [MERGEJOIN_1068] (rows=2331650 width=1292) - Conds:RS_118._col37=RS_1120._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col49","_col56"] + 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] PartitionCols:_col0 @@ -352,27 +352,27 @@ Stage-0 Output:["_col0","_col1"] Filter Operator [FIL_1118] (rows=1861800 width=89) predicate:cd_demo_sk is not null - TableScan [TS_97] (rows=1861800 width=89) + 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_118] + SHUFFLE [RS_117] PartitionCols:_col37 Merge Join Operator [MERGEJOIN_1067] (rows=2299138 width=1205) - Conds:RS_115._col0=RS_116._col16(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col37","_col43","_col44","_col45","_col46","_col49"] + 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_115] + SHUFFLE [RS_114] PartitionCols:_col0 Merge Join Operator [MERGEJOIN_1056] (rows=70357394 width=458) - Conds:RS_112._col1=RS_1121._col0(Inner),Output:["_col0","_col7","_col9","_col14","_col15","_col16","_col17","_col19"] + 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] PartitionCols:_col0 Please refer to the previous Select Operator [SEL_1119] <-Reducer 5 [SIMPLE_EDGE] - SHUFFLE [RS_112] + SHUFFLE [RS_111] PartitionCols:_col1 Merge Join Operator [MERGEJOIN_1055] (rows=69376329 width=376) - Conds:RS_109._col3=RS_1115._col0(Inner),Output:["_col0","_col1","_col7","_col9","_col14","_col15","_col16","_col17"] + 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] PartitionCols:_col0 @@ -383,12 +383,12 @@ Stage-0 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"] <-Reducer 4 [SIMPLE_EDGE] - SHUFFLE [RS_109] + SHUFFLE [RS_108] PartitionCols:_col3 Merge Join Operator [MERGEJOIN_1054] (rows=69376329 width=19) - Conds:RS_106._col2=RS_107._col0(Inner),Output:["_col0","_col1","_col3","_col7","_col9"] + Conds:RS_105._col2=RS_106._col0(Inner),Output:["_col0","_col1","_col3","_col7","_col9"] <-Reducer 34 [SIMPLE_EDGE] - SHUFFLE [RS_107] + SHUFFLE [RS_106] PartitionCols:_col0 Merge Join Operator [MERGEJOIN_1053] (rows=7200 width=4) Conds:RS_1109._col1=RS_1112._col0(Inner),Output:["_col0"] @@ -411,10 +411,10 @@ Stage-0 TableScan [TS_12] (rows=20 width=4) default@income_band,ib2,Tbl:COMPLETE,Col:COMPLETE,Output:["ib_income_band_sk"] <-Reducer 3 [SIMPLE_EDGE] - SHUFFLE [RS_106] + SHUFFLE [RS_105] PartitionCols:_col2 Merge Join Operator [MERGEJOIN_1052] (rows=69376329 width=23) - Conds:RS_103._col4=RS_1098._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col7","_col9"] + 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] PartitionCols:_col0 @@ -425,7 +425,7 @@ Stage-0 TableScan [TS_3] (rows=73049 width=8) default@date_dim,d2,Tbl:COMPLETE,Col:COMPLETE,Output:["d_date_sk","d_year"] <-Reducer 2 [SIMPLE_EDGE] - SHUFFLE [RS_103] + SHUFFLE [RS_102] 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"] @@ -443,12 +443,12 @@ Stage-0 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_116] + SHUFFLE [RS_115] PartitionCols:_col16 - Select Operator [SEL_96] (rows=2651207 width=784) - Output:["_col3","_col4","_col5","_col6","_col8","_col9","_col16","_col17","_col23","_col24","_col25","_col26","_col29"] + 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_1066] (rows=2651207 width=784) - Conds:RS_93._col5, _col12=RS_1167._col0, _col1(Inner),Output:["_col6","_col7","_col13","_col14","_col15","_col16","_col19","_col26","_col27","_col29","_col30","_col31","_col32"] + 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] PartitionCols:_col0, _col1 @@ -456,22 +456,22 @@ Stage-0 Output:["_col0","_col1"] Filter Operator [FIL_1165] (rows=57591150 width=8) predicate:(sr_item_sk is not null and sr_ticket_number is not null) - TableScan [TS_75] (rows=57591150 width=8) + 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_93] + SHUFFLE [RS_92] PartitionCols:_col5, _col12 Merge Join Operator [MERGEJOIN_1065] (rows=1608052 width=657) - Conds:RS_90._col9=RS_1116._col0(Inner),Output:["_col5","_col6","_col7","_col12","_col13","_col14","_col15","_col16","_col19","_col26","_col27","_col29","_col30","_col31","_col32"] + 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] PartitionCols:_col0 Please refer to the previous Select Operator [SEL_1114] <-Reducer 21 [SIMPLE_EDGE] - SHUFFLE [RS_90] + SHUFFLE [RS_89] PartitionCols:_col9 Merge Join Operator [MERGEJOIN_1064] (rows=1608052 width=296) - Conds:RS_87._col10=RS_1163._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col12","_col13","_col14","_col15","_col16","_col19","_col26","_col27"] + 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] PartitionCols:_col0 @@ -479,108 +479,106 @@ Stage-0 Output:["_col0","_col1","_col2"] Filter Operator [FIL_1161] (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_69] (rows=1704 width=181) + 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_87] + SHUFFLE [RS_86] PartitionCols:_col10 Merge Join Operator [MERGEJOIN_1063] (rows=1608052 width=119) - Conds:RS_84._col5=RS_1148._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col19"] - <-Reducer 46 [ONE_TO_ONE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1148] + 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] PartitionCols:_col0 - Select Operator [SEL_1147] (rows=13257 width=228) - Output:["_col0"] - Filter Operator [FIL_1146] (rows=13257 width=228) - predicate:(_col1 > (2 * _col2)) - Group By Operator [GBY_1145] (rows=39773 width=228) - Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0 - <-Reducer 45 [SIMPLE_EDGE] - SHUFFLE [RS_65] - PartitionCols:_col0 - Group By Operator [GBY_64] (rows=12806906 width=228) - Output:["_col0","_col1","_col2"],aggregations:["sum(_col1)","sum(_col2)"],keys:_col0 - Select Operator [SEL_62] (rows=183085709 width=450) - Output:["_col0","_col1","_col2"] - Merge Join Operator [MERGEJOIN_1061] (rows=183085709 width=450) - Conds:RS_1140._col0, _col1=RS_1143._col0, _col1(Inner),Output:["_col0","_col2","_col5","_col6","_col7"] - <-Map 48 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1143] - PartitionCols:_col0, _col1 - Select Operator [SEL_1142] (rows=28798881 width=337) - Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_1141] (rows=28798881 width=337) - predicate:(cr_item_sk is not null and cr_order_number is not null) - TableScan [TS_56] (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 44 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1140] - PartitionCols:_col0, _col1 - Select Operator [SEL_1139] (rows=287989836 width=119) - Output:["_col0","_col1","_col2"] - Filter Operator [FIL_1138] (rows=287989836 width=119) - predicate:((cs_item_sk BETWEEN DynamicValue(RS_44_item_i_item_sk_min) AND DynamicValue(RS_44_item_i_item_sk_max) and in_bloom_filter(cs_item_sk, DynamicValue(RS_44_item_i_item_sk_bloom_filter))) and cs_item_sk is not null and cs_order_number is not null) - TableScan [TS_53] (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=312) - Output:["_col0","_col3"] - 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"] + Please refer to the previous Merge Join Operator [MERGEJOIN_1053] <-Reducer 19 [SIMPLE_EDGE] SHUFFLE [RS_84] PartitionCols:_col5 - Merge Join Operator [MERGEJOIN_1062] (rows=1608052 width=119) - Conds:RS_81._col0=RS_82._col5(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col19"] - <-Reducer 34 [SIMPLE_EDGE] - SHUFFLE [RS_81] - PartitionCols:_col0 - Please refer to the previous Merge Join Operator [MERGEJOIN_1053] - <-Reducer 18 [SIMPLE_EDGE] - SHUFFLE [RS_82] - PartitionCols:_col5 - Select Operator [SEL_52] (rows=1608052 width=119) - Output:["_col2","_col3","_col4","_col5","_col6","_col7","_col9","_col10","_col11","_col12","_col13","_col16"] - Merge Join Operator [MERGEJOIN_1060] (rows=1608052 width=119) - Conds:RS_49._col7=RS_1159._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col8","_col9","_col10","_col11","_col12","_col15"] - <-Map 43 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1159] + 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_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] + PartitionCols:_col0 + Select Operator [SEL_1158] (rows=2300 width=4) + Output:["_col0"] + Filter Operator [FIL_1157] (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] + 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"] + <-Reducer 45 [ONE_TO_ONE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_1148] PartitionCols:_col0 - Select Operator [SEL_1158] (rows=2300 width=4) + Select Operator [SEL_1147] (rows=13257 width=4) Output:["_col0"] - Filter Operator [FIL_1157] (rows=2300 width=4) - predicate:p_promo_sk is not null - TableScan [TS_40] (rows=2300 width=4) - default@promotion,promotion,Tbl:COMPLETE,Col:COMPLETE,Output:["p_promo_sk"] + Filter Operator [FIL_1146] (rows=13257 width=228) + predicate:(_col1 > (2 * _col2)) + Group By Operator [GBY_1145] (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] + PartitionCols:_col0 + Group By Operator [GBY_50] (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] + PartitionCols:_col0, _col1 + Select Operator [SEL_1142] (rows=28798881 width=120) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_1141] (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] + PartitionCols:_col0, _col1 + Select Operator [SEL_1139] (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) + 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_49] - PartitionCols:_col7 + SHUFFLE [RS_64] + PartitionCols:_col1 Merge Join Operator [MERGEJOIN_1059] (rows=1608052 width=119) - Conds:RS_46._col0=RS_1099._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col15"] + 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=8) + 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_46] + 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","_col15"] + 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 @@ -591,7 +589,7 @@ Stage-0 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_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_item_sk BETWEEN DynamicValue(RS_85_catalog_sales_cs_item_sk_min) AND DynamicValue(RS_85_catalog_sales_cs_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_85_catalog_sales_cs_item_sk_bloom_filter))) and (ss_sold_date_sk BETWEEN DynamicValue(RS_47_d1_d_date_sk_min) AND DynamicValue(RS_47_d1_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_47_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) + 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 @@ -608,11 +606,11 @@ Stage-0 Select Operator [SEL_1100] (rows=652 width=4) Output:["_col0"] Please refer to the previous Select Operator [SEL_1095] - <-Reducer 47 [BROADCAST_EDGE] vectorized + <-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 46 [CUSTOM_SIMPLE_EDGE] vectorized + <-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)"] @@ -627,143 +625,141 @@ Stage-0 Group By Operator [GBY_1197] (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_251] + SHUFFLE [RS_249] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, _col11, _col12, _col13 - Group By Operator [GBY_250] (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, _col49 - Select Operator [SEL_249] (rows=2331650 width=1292) - Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col49"] - Filter Operator [FIL_248] (rows=2331650 width=1292) - predicate:(_col56 <> _col19) + 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_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_246] (rows=2331650 width=1292) + predicate:(_col51 <> _col19) Merge Join Operator [MERGEJOIN_1086] (rows=2331650 width=1292) - Conds:RS_245._col37=RS_1122._col0(Inner),Output:["_col7","_col9","_col14","_col15","_col16","_col17","_col19","_col23","_col24","_col25","_col26","_col28","_col29","_col43","_col44","_col45","_col46","_col49","_col56"] + 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] PartitionCols:_col0 Please refer to the previous Select Operator [SEL_1119] <-Reducer 13 [SIMPLE_EDGE] - SHUFFLE [RS_245] + SHUFFLE [RS_243] PartitionCols:_col37 Merge Join Operator [MERGEJOIN_1085] (rows=2299138 width=1205) - 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"] + 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_242] + SHUFFLE [RS_240] PartitionCols:_col0 Please refer to the previous Merge Join Operator [MERGEJOIN_1056] <-Reducer 31 [SIMPLE_EDGE] - SHUFFLE [RS_243] + SHUFFLE [RS_241] PartitionCols:_col16 - Select Operator [SEL_223] (rows=2651207 width=784) - Output:["_col3","_col4","_col5","_col6","_col8","_col9","_col16","_col17","_col23","_col24","_col25","_col26","_col29"] + 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_1084] (rows=2651207 width=784) - Conds:RS_220._col5, _col12=RS_1168._col0, _col1(Inner),Output:["_col6","_col7","_col13","_col14","_col15","_col16","_col19","_col26","_col27","_col29","_col30","_col31","_col32"] + 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] PartitionCols:_col0, _col1 Please refer to the previous Select Operator [SEL_1166] <-Reducer 30 [SIMPLE_EDGE] - SHUFFLE [RS_220] + SHUFFLE [RS_218] PartitionCols:_col5, _col12 Merge Join Operator [MERGEJOIN_1083] (rows=1608052 width=657) - Conds:RS_217._col9=RS_1117._col0(Inner),Output:["_col5","_col6","_col7","_col12","_col13","_col14","_col15","_col16","_col19","_col26","_col27","_col29","_col30","_col31","_col32"] + 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] PartitionCols:_col0 Please refer to the previous Select Operator [SEL_1114] <-Reducer 29 [SIMPLE_EDGE] - SHUFFLE [RS_217] + SHUFFLE [RS_215] PartitionCols:_col9 Merge Join Operator [MERGEJOIN_1082] (rows=1608052 width=296) - Conds:RS_214._col10=RS_1164._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col12","_col13","_col14","_col15","_col16","_col19","_col26","_col27"] + 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] PartitionCols:_col0 Please refer to the previous Select Operator [SEL_1162] <-Reducer 28 [SIMPLE_EDGE] - SHUFFLE [RS_214] + SHUFFLE [RS_212] PartitionCols:_col10 Merge Join Operator [MERGEJOIN_1081] (rows=1608052 width=119) - Conds:RS_211._col5=RS_1186._col0(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col19"] - <-Reducer 50 [ONE_TO_ONE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_1186] + 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] PartitionCols:_col0 - Select Operator [SEL_1185] (rows=13257 width=228) - 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 49 [SIMPLE_EDGE] - SHUFFLE [RS_192] - PartitionCols:_col0 - Group By Operator [GBY_191] (rows=12806906 width=228) - Output:["_col0","_col1","_col2"],aggregations:["sum(_col1)","sum(_col2)"],keys:_col0 - Select Operator [SEL_189] (rows=183085709 width=450) - Output:["_col0","_col1","_col2"] - Merge Join Operator [MERGEJOIN_1079] (rows=183085709 width=450) - Conds:RS_1182._col0, _col1=RS_1144._col0, _col1(Inner),Output:["_col0","_col2","_col5","_col6","_col7"] - <-Map 48 [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_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 is not null and cs_order_number is not null) - TableScan [TS_180] (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] + Please refer to the previous Merge Join Operator [MERGEJOIN_1053] <-Reducer 27 [SIMPLE_EDGE] - SHUFFLE [RS_211] + SHUFFLE [RS_210] PartitionCols:_col5 - Merge Join Operator [MERGEJOIN_1080] (rows=1608052 width=119) - Conds:RS_208._col0=RS_209._col5(Inner),Output:["_col5","_col6","_col7","_col9","_col10","_col12","_col13","_col14","_col15","_col16","_col19"] - <-Reducer 34 [SIMPLE_EDGE] - SHUFFLE [RS_208] - PartitionCols:_col0 - Please refer to the previous Merge Join Operator [MERGEJOIN_1053] - <-Reducer 26 [SIMPLE_EDGE] - SHUFFLE [RS_209] - PartitionCols:_col5 - Select Operator [SEL_179] (rows=1608052 width=119) - Output:["_col2","_col3","_col4","_col5","_col6","_col7","_col9","_col10","_col11","_col12","_col13","_col16"] - Merge Join Operator [MERGEJOIN_1078] (rows=1608052 width=119) - Conds:RS_176._col7=RS_1160._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col8","_col9","_col10","_col11","_col12","_col15"] - <-Map 43 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_1160] + 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_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] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_1158] + <-Reducer 26 [SIMPLE_EDGE] + SHUFFLE [RS_193] + 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 - Please refer to the previous Select Operator [SEL_1158] + 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_176] - PartitionCols:_col7 + SHUFFLE [RS_190] + PartitionCols:_col1 Merge Join Operator [MERGEJOIN_1077] (rows=1608052 width=119) - Conds:RS_173._col0=RS_1101._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col15"] + 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] PartitionCols:_col0 - Select Operator [SEL_1096] (rows=652 width=8) + 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 41 [SIMPLE_EDGE] - SHUFFLE [RS_173] + SHUFFLE [RS_187] 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","_col15"] + 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] PartitionCols:_col0 @@ -774,8 +770,8 @@ Stage-0 Select Operator [SEL_1195] (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_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 in_bloom_filter(ss_item_sk, DynamicValue(RS_212_catalog_sales_cs_item_sk_bloom_filter))) and (ss_item_sk BETWEEN DynamicValue(RS_254_item_i_item_sk_min) AND DynamicValue(RS_254_item_i_item_sk_max) and in_bloom_filter(ss_item_sk, DynamicValue(RS_254_item_i_item_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_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_158] (rows=575995635 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) 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] @@ -802,11 +798,11 @@ Stage-0 Select Operator [SEL_1102] (rows=652 width=4) Output:["_col0"] Please refer to the previous Select Operator [SEL_1096] - <-Reducer 51 [BROADCAST_EDGE] vectorized + <-Reducer 50 [BROADCAST_EDGE] vectorized BROADCAST [RS_1191] Group By Operator [GBY_1190] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Reducer 50 [CUSTOM_SIMPLE_EDGE] vectorized + <-Reducer 49 [CUSTOM_SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_1189] Group By Operator [GBY_1188] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"]
http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query65.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query65.q.out b/ql/src/test/results/clientpositive/perf/tez/query65.q.out index 4c3644b..fc2a6c9 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query65.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query65.q.out @@ -124,7 +124,7 @@ Stage-0 FORWARD [RS_43] PartitionCols:_col0 Filter Operator [FIL_42] (rows=65392 width=231) - predicate:(_col2 <= (0.1 * _col4)) + predicate:(_col2 <= _col4) Merge Join Operator [MERGEJOIN_134] (rows=196176 width=231) Conds:RS_153._col0=RS_168._col0(Inner),Output:["_col0","_col1","_col2","_col4"] <-Reducer 3 [SIMPLE_EDGE] vectorized @@ -142,7 +142,7 @@ Stage-0 <-Map 9 [SIMPLE_EDGE] vectorized SHUFFLE [RS_139] PartitionCols:_col0 - Select Operator [SEL_138] (rows=317 width=8) + Select Operator [SEL_138] (rows=317 width=4) Output:["_col0"] Filter Operator [FIL_137] (rows=317 width=8) predicate:(d_date_sk is not null and d_month_seq BETWEEN 1212 AND 1223)