http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query4.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query4.q.out b/ql/src/test/results/clientpositive/perf/tez/query4.q.out index 27ce7b5..bb0d7ba 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query4.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query4.q.out @@ -271,367 +271,355 @@ Stage-0 limit:100 Stage-1 Reducer 10 vectorized - File Output Operator [FS_575] - Limit [LIM_574] (rows=100 width=85) + File Output Operator [FS_557] + Limit [LIM_556] (rows=100 width=85) Number of rows:100 - Select Operator [SEL_573] (rows=7323197 width=85) + Select Operator [SEL_555] (rows=7323197 width=85) Output:["_col0"] <-Reducer 9 [SIMPLE_EDGE] - SHUFFLE [RS_147] - Select Operator [SEL_146] (rows=7323197 width=85) + SHUFFLE [RS_141] + Select Operator [SEL_140] (rows=7323197 width=85) Output:["_col0"] - Filter Operator [FIL_145] (rows=7323197 width=533) - predicate:CASE WHEN (_col3 is not null) THEN (CASE WHEN (_col5 is not null) THEN (((_col9 / _col5) > (_col12 / _col3))) ELSE ((null > (_col12 / _col3))) END) ELSE (CASE WHEN (_col5 is not null) THEN (((_col9 / _col5) > null)) ELSE (null) END) END - Merge Join Operator [MERGEJOIN_478] (rows=14646395 width=533) - Conds:RS_142._col2=RS_572._col0(Inner),Output:["_col3","_col5","_col9","_col11","_col12"] + Filter Operator [FIL_139] (rows=7323197 width=537) + predicate:CASE WHEN (_col3 is not null) THEN (CASE WHEN (_col9) THEN (((_col11 / _col8) > (_col14 / _col3))) ELSE ((null > (_col14 / _col3))) END) ELSE (CASE WHEN (_col9) THEN (((_col11 / _col8) > null)) ELSE (null) END) END + Merge Join Operator [MERGEJOIN_472] (rows=14646395 width=537) + Conds:RS_136._col2=RS_554._col0(Inner),Output:["_col3","_col8","_col9","_col11","_col13","_col14"] <-Reducer 30 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_572] + SHUFFLE [RS_554] PartitionCols:_col0 - Select Operator [SEL_571] (rows=80000000 width=297) + Select Operator [SEL_553] (rows=80000000 width=297) Output:["_col0","_col1","_col2"] - Group By Operator [GBY_570] (rows=80000000 width=764) + Group By Operator [GBY_552] (rows=80000000 width=764) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4, KEY._col5, KEY._col6 <-Reducer 29 [SIMPLE_EDGE] - SHUFFLE [RS_126] + SHUFFLE [RS_120] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Group By Operator [GBY_125] (rows=80000000 width=764) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col7)"],keys:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Select Operator [SEL_123] (rows=187573258 width=1043) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] - Merge Join Operator [MERGEJOIN_473] (rows=187573258 width=1043) - Conds:RS_120._col1=RS_518._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9","_col10","_col11","_col12","_col13","_col14","_col15"] - <-Map 38 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_518] - PartitionCols:_col0 - Select Operator [SEL_517] (rows=80000000 width=656) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] - Filter Operator [FIL_516] (rows=80000000 width=656) - predicate:(c_customer_id is not null and c_customer_sk is not null) - TableScan [TS_114] (rows=80000000 width=656) - default@customer,customer,Tbl:COMPLETE,Col:COMPLETE,Output:["c_customer_sk","c_customer_id","c_first_name","c_last_name","c_preferred_cust_flag","c_birth_country","c_login","c_email_address"] - <-Reducer 28 [SIMPLE_EDGE] - SHUFFLE [RS_120] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_472] (rows=187573258 width=395) - Conds:RS_569._col0=RS_487._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"] - <-Map 31 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_487] - PartitionCols:_col0 - Select Operator [SEL_483] (rows=652 width=8) - Output:["_col0"] - Filter Operator [FIL_479] (rows=652 width=8) - predicate:((d_year = 2002) and d_date_sk is not null) - TableScan [TS_111] (rows=73049 width=8) - default@date_dim,date_dim,Tbl:COMPLETE,Col:COMPLETE,Output:["d_date_sk","d_year"] - <-Map 27 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_569] - PartitionCols:_col0 - Select Operator [SEL_568] (rows=525327388 width=435) - Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_567] (rows=525327388 width=435) - predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_118_date_dim_d_date_sk_min) AND DynamicValue(RS_118_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_118_date_dim_d_date_sk_bloom_filter))) and ss_customer_sk is not null and ss_sold_date_sk is not null) - TableScan [TS_108] (rows=575995635 width=435) - default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_customer_sk","ss_ext_discount_amt","ss_ext_sales_price","ss_ext_wholesale_cost","ss_ext_list_price"] - <-Reducer 32 [BROADCAST_EDGE] vectorized - BROADCAST [RS_566] - Group By Operator [GBY_565] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_505] - Group By Operator [GBY_499] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_488] (rows=652 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_483] + Group By Operator [GBY_119] (rows=80000000 width=764) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col2)"],keys:_col5, _col6, _col7, _col8, _col9, _col10, _col11 + Merge Join Operator [MERGEJOIN_467] (rows=187573258 width=764) + Conds:RS_115._col1=RS_510._col0(Inner),Output:["_col2","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] + <-Map 38 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_510] + PartitionCols:_col0 + Select Operator [SEL_509] (rows=80000000 width=656) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] + Filter Operator [FIL_508] (rows=80000000 width=656) + predicate:(c_customer_id is not null and c_customer_sk is not null) + TableScan [TS_109] (rows=80000000 width=656) + default@customer,customer,Tbl:COMPLETE,Col:COMPLETE,Output:["c_customer_sk","c_customer_id","c_first_name","c_last_name","c_preferred_cust_flag","c_birth_country","c_login","c_email_address"] + <-Reducer 28 [SIMPLE_EDGE] + SHUFFLE [RS_115] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_466] (rows=187573258 width=115) + Conds:RS_112._col0=RS_481._col0(Inner),Output:["_col1","_col2"] + <-Map 31 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_481] + PartitionCols:_col0 + Select Operator [SEL_477] (rows=652 width=4) + Output:["_col0"] + Filter Operator [FIL_473] (rows=652 width=8) + predicate:((d_year = 2002) and d_date_sk is not null) + TableScan [TS_106] (rows=73049 width=8) + default@date_dim,date_dim,Tbl:COMPLETE,Col:COMPLETE,Output:["d_date_sk","d_year"] + <-Map 27 [SIMPLE_EDGE] + SHUFFLE [RS_112] + PartitionCols:_col0 + Select Operator [SEL_105] (rows=525327388 width=119) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_250] (rows=525327388 width=435) + predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_113_date_dim_d_date_sk_min) AND DynamicValue(RS_113_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_113_date_dim_d_date_sk_bloom_filter))) and ss_customer_sk is not null and ss_sold_date_sk is not null) + TableScan [TS_103] (rows=575995635 width=435) + default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_customer_sk","ss_ext_discount_amt","ss_ext_sales_price","ss_ext_wholesale_cost","ss_ext_list_price"] + <-Reducer 32 [BROADCAST_EDGE] vectorized + BROADCAST [RS_550] + Group By Operator [GBY_549] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_499] + Group By Operator [GBY_493] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_482] (rows=652 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_477] <-Reducer 8 [ONE_TO_ONE_EDGE] - FORWARD [RS_142] + FORWARD [RS_136] PartitionCols:_col2 - Filter Operator [FIL_141] (rows=12248093 width=660) - predicate:CASE WHEN (_col7 is not null) THEN (CASE WHEN (_col5 is not null) THEN (((_col9 / _col5) > (_col1 / _col7))) ELSE ((null > (_col1 / _col7))) END) ELSE (CASE WHEN (_col5 is not null) THEN (((_col9 / _col5) > null)) ELSE (null) END) END - Merge Join Operator [MERGEJOIN_477] (rows=24496186 width=660) - Conds:RS_138._col2=RS_564._col0(Inner),Output:["_col1","_col2","_col3","_col5","_col7","_col9"] + Filter Operator [FIL_135] (rows=12248093 width=668) + predicate:CASE WHEN (_col6) THEN (CASE WHEN (_col9) THEN (((_col11 / _col8) > (_col1 / _col5))) ELSE ((null > (_col1 / _col5))) END) ELSE (CASE WHEN (_col9) THEN (((_col11 / _col8) > null)) ELSE (null) END) END + Merge Join Operator [MERGEJOIN_471] (rows=24496186 width=668) + Conds:RS_132._col2=RS_548._col0(Inner),Output:["_col1","_col2","_col3","_col5","_col6","_col8","_col9","_col11"] <-Reducer 26 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_564] + SHUFFLE [RS_548] PartitionCols:_col0 - Select Operator [SEL_563] (rows=80000000 width=212) + Select Operator [SEL_547] (rows=80000000 width=212) Output:["_col0","_col1"] - Group By Operator [GBY_562] (rows=80000000 width=764) + Group By Operator [GBY_546] (rows=80000000 width=764) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4, KEY._col5, KEY._col6 <-Reducer 25 [SIMPLE_EDGE] - SHUFFLE [RS_105] + SHUFFLE [RS_100] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Group By Operator [GBY_104] (rows=80000000 width=764) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col7)"],keys:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Select Operator [SEL_102] (rows=101084444 width=1093) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] - Merge Join Operator [MERGEJOIN_471] (rows=101084444 width=1093) - Conds:RS_99._col1=RS_519._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9","_col10","_col11","_col12","_col13","_col14","_col15"] - <-Map 38 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_519] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_517] - <-Reducer 24 [SIMPLE_EDGE] - SHUFFLE [RS_99] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_470] (rows=101084444 width=445) - Conds:RS_561._col0=RS_489._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"] - <-Map 31 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_489] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_483] - <-Map 23 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_561] - PartitionCols:_col0 - Select Operator [SEL_560] (rows=285117831 width=453) - Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_559] (rows=285117831 width=453) - predicate:((cs_sold_date_sk BETWEEN DynamicValue(RS_97_date_dim_d_date_sk_min) AND DynamicValue(RS_97_date_dim_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_97_date_dim_d_date_sk_bloom_filter))) and cs_bill_customer_sk is not null and cs_sold_date_sk is not null) - TableScan [TS_87] (rows=287989836 width=453) - default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["cs_sold_date_sk","cs_bill_customer_sk","cs_ext_discount_amt","cs_ext_sales_price","cs_ext_wholesale_cost","cs_ext_list_price"] - <-Reducer 33 [BROADCAST_EDGE] vectorized - BROADCAST [RS_558] - Group By Operator [GBY_557] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_506] - Group By Operator [GBY_500] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_490] (rows=652 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_483] + Group By Operator [GBY_99] (rows=80000000 width=764) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col2)"],keys:_col5, _col6, _col7, _col8, _col9, _col10, _col11 + Merge Join Operator [MERGEJOIN_465] (rows=101084444 width=764) + Conds:RS_95._col1=RS_511._col0(Inner),Output:["_col2","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] + <-Map 38 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_511] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_509] + <-Reducer 24 [SIMPLE_EDGE] + SHUFFLE [RS_95] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_464] (rows=101084444 width=115) + Conds:RS_92._col0=RS_483._col0(Inner),Output:["_col1","_col2"] + <-Map 31 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_483] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_477] + <-Map 23 [SIMPLE_EDGE] + SHUFFLE [RS_92] + PartitionCols:_col0 + Select Operator [SEL_85] (rows=285117831 width=119) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_247] (rows=285117831 width=453) + predicate:((cs_sold_date_sk BETWEEN DynamicValue(RS_93_date_dim_d_date_sk_min) AND DynamicValue(RS_93_date_dim_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_93_date_dim_d_date_sk_bloom_filter))) and cs_bill_customer_sk is not null and cs_sold_date_sk is not null) + TableScan [TS_83] (rows=287989836 width=453) + default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["cs_sold_date_sk","cs_bill_customer_sk","cs_ext_discount_amt","cs_ext_sales_price","cs_ext_wholesale_cost","cs_ext_list_price"] + <-Reducer 33 [BROADCAST_EDGE] vectorized + BROADCAST [RS_544] + Group By Operator [GBY_543] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_500] + Group By Operator [GBY_494] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_484] (rows=652 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_477] <-Reducer 7 [ONE_TO_ONE_EDGE] - FORWARD [RS_138] + FORWARD [RS_132] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_476] (rows=20485011 width=548) - Conds:RS_135._col2=RS_556._col0(Inner),Output:["_col1","_col2","_col3","_col5","_col7"] + Merge Join Operator [MERGEJOIN_470] (rows=20485011 width=556) + Conds:RS_129._col2=RS_542._col0(Inner),Output:["_col1","_col2","_col3","_col5","_col6","_col8","_col9"] <-Reducer 22 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_556] + SHUFFLE [RS_542] PartitionCols:_col0 - Select Operator [SEL_555] (rows=17130654 width=212) - Output:["_col0","_col1"] - Filter Operator [FIL_554] (rows=17130654 width=212) + Select Operator [SEL_541] (rows=26666666 width=216) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_540] (rows=26666666 width=212) predicate:(_col7 > 0) - Select Operator [SEL_553] (rows=51391963 width=212) + Select Operator [SEL_539] (rows=80000000 width=212) Output:["_col0","_col7"] - Group By Operator [GBY_552] (rows=51391963 width=764) + Group By Operator [GBY_538] (rows=80000000 width=764) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4, KEY._col5, KEY._col6 <-Reducer 21 [SIMPLE_EDGE] - SHUFFLE [RS_83] + SHUFFLE [RS_79] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Group By Operator [GBY_82] (rows=51391963 width=764) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col7)"],keys:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Select Operator [SEL_80] (rows=51391963 width=1099) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] - Merge Join Operator [MERGEJOIN_469] (rows=51391963 width=1099) - Conds:RS_77._col1=RS_523._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9","_col10","_col11","_col12","_col13","_col14","_col15"] - <-Map 38 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_523] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_517] - <-Reducer 20 [SIMPLE_EDGE] - SHUFFLE [RS_77] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_468] (rows=51391963 width=451) - Conds:RS_551._col0=RS_497._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"] - <-Map 31 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_497] - PartitionCols:_col0 - Select Operator [SEL_486] (rows=652 width=8) - Output:["_col0"] - Filter Operator [FIL_482] (rows=652 width=8) - predicate:((d_year = 2001) and d_date_sk is not null) - Please refer to the previous TableScan [TS_111] - <-Map 19 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_551] - PartitionCols:_col0 - Select Operator [SEL_550] (rows=143930993 width=455) - Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_549] (rows=143930993 width=455) - predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_75_date_dim_d_date_sk_min) AND DynamicValue(RS_75_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_75_date_dim_d_date_sk_bloom_filter))) and ws_bill_customer_sk is not null and ws_sold_date_sk is not null) - TableScan [TS_65] (rows=144002668 width=455) - default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_customer_sk","ws_ext_discount_amt","ws_ext_sales_price","ws_ext_wholesale_cost","ws_ext_list_price"] - <-Reducer 37 [BROADCAST_EDGE] vectorized - BROADCAST [RS_548] - Group By Operator [GBY_547] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_510] - Group By Operator [GBY_504] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_498] (rows=652 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_486] + Group By Operator [GBY_78] (rows=80000000 width=764) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col2)"],keys:_col5, _col6, _col7, _col8, _col9, _col10, _col11 + Merge Join Operator [MERGEJOIN_463] (rows=101084444 width=764) + Conds:RS_74._col1=RS_515._col0(Inner),Output:["_col2","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] + <-Map 38 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_515] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_509] + <-Reducer 20 [SIMPLE_EDGE] + SHUFFLE [RS_74] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_462] (rows=101084444 width=115) + Conds:RS_71._col0=RS_491._col0(Inner),Output:["_col1","_col2"] + <-Map 31 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_491] + PartitionCols:_col0 + Select Operator [SEL_480] (rows=652 width=4) + Output:["_col0"] + Filter Operator [FIL_476] (rows=652 width=8) + predicate:((d_year = 2001) and d_date_sk is not null) + Please refer to the previous TableScan [TS_106] + <-Map 19 [SIMPLE_EDGE] + SHUFFLE [RS_71] + PartitionCols:_col0 + Select Operator [SEL_64] (rows=285117831 width=119) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_244] (rows=285117831 width=453) + predicate:((cs_sold_date_sk BETWEEN DynamicValue(RS_72_date_dim_d_date_sk_min) AND DynamicValue(RS_72_date_dim_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_72_date_dim_d_date_sk_bloom_filter))) and cs_bill_customer_sk is not null and cs_sold_date_sk is not null) + TableScan [TS_62] (rows=287989836 width=453) + default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["cs_sold_date_sk","cs_bill_customer_sk","cs_ext_discount_amt","cs_ext_sales_price","cs_ext_wholesale_cost","cs_ext_list_price"] + <-Reducer 37 [BROADCAST_EDGE] vectorized + BROADCAST [RS_536] + Group By Operator [GBY_535] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_504] + Group By Operator [GBY_498] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_492] (rows=652 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_480] <-Reducer 6 [ONE_TO_ONE_EDGE] - FORWARD [RS_135] + FORWARD [RS_129] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_475] (rows=31888273 width=436) - Conds:RS_132._col2=RS_546._col0(Inner),Output:["_col1","_col2","_col3","_col5"] + Merge Join Operator [MERGEJOIN_469] (rows=20485011 width=440) + Conds:RS_126._col2=RS_534._col0(Inner),Output:["_col1","_col2","_col3","_col5","_col6"] <-Reducer 18 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_546] + SHUFFLE [RS_534] PartitionCols:_col0 - Select Operator [SEL_545] (rows=26666666 width=212) - Output:["_col0","_col1"] - Filter Operator [FIL_544] (rows=26666666 width=212) + Select Operator [SEL_533] (rows=17130654 width=216) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_532] (rows=17130654 width=212) predicate:(_col7 > 0) - Select Operator [SEL_543] (rows=80000000 width=212) + Select Operator [SEL_531] (rows=51391963 width=212) Output:["_col0","_col7"] - Group By Operator [GBY_542] (rows=80000000 width=764) + Group By Operator [GBY_530] (rows=51391963 width=764) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4, KEY._col5, KEY._col6 <-Reducer 17 [SIMPLE_EDGE] - SHUFFLE [RS_61] + SHUFFLE [RS_58] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Group By Operator [GBY_60] (rows=80000000 width=764) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col7)"],keys:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Select Operator [SEL_58] (rows=101084444 width=1093) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] - Merge Join Operator [MERGEJOIN_467] (rows=101084444 width=1093) - Conds:RS_55._col1=RS_522._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9","_col10","_col11","_col12","_col13","_col14","_col15"] - <-Map 38 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_522] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_517] - <-Reducer 16 [SIMPLE_EDGE] - SHUFFLE [RS_55] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_466] (rows=101084444 width=445) - Conds:RS_541._col0=RS_495._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"] - <-Map 31 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_495] - PartitionCols:_col0 - Select Operator [SEL_485] (rows=652 width=8) - Output:["_col0"] - Filter Operator [FIL_481] (rows=652 width=8) - predicate:((d_year = 2001) and d_date_sk is not null) - Please refer to the previous TableScan [TS_111] - <-Map 15 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_541] - PartitionCols:_col0 - Select Operator [SEL_540] (rows=285117831 width=453) - Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_539] (rows=285117831 width=453) - predicate:((cs_sold_date_sk BETWEEN DynamicValue(RS_53_date_dim_d_date_sk_min) AND DynamicValue(RS_53_date_dim_d_date_sk_max) and in_bloom_filter(cs_sold_date_sk, DynamicValue(RS_53_date_dim_d_date_sk_bloom_filter))) and cs_bill_customer_sk is not null and cs_sold_date_sk is not null) - TableScan [TS_43] (rows=287989836 width=453) - default@catalog_sales,catalog_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["cs_sold_date_sk","cs_bill_customer_sk","cs_ext_discount_amt","cs_ext_sales_price","cs_ext_wholesale_cost","cs_ext_list_price"] - <-Reducer 36 [BROADCAST_EDGE] vectorized - BROADCAST [RS_538] - Group By Operator [GBY_537] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_509] - Group By Operator [GBY_503] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_496] (rows=652 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_485] + Group By Operator [GBY_57] (rows=51391963 width=764) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col2)"],keys:_col5, _col6, _col7, _col8, _col9, _col10, _col11 + Merge Join Operator [MERGEJOIN_461] (rows=51391963 width=764) + Conds:RS_53._col1=RS_514._col0(Inner),Output:["_col2","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] + <-Map 38 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_514] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_509] + <-Reducer 16 [SIMPLE_EDGE] + SHUFFLE [RS_53] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_460] (rows=51391963 width=115) + Conds:RS_50._col0=RS_489._col0(Inner),Output:["_col1","_col2"] + <-Map 31 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_489] + PartitionCols:_col0 + Select Operator [SEL_479] (rows=652 width=4) + Output:["_col0"] + Filter Operator [FIL_475] (rows=652 width=8) + predicate:((d_year = 2001) and d_date_sk is not null) + Please refer to the previous TableScan [TS_106] + <-Map 15 [SIMPLE_EDGE] + SHUFFLE [RS_50] + PartitionCols:_col0 + Select Operator [SEL_43] (rows=143930993 width=119) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_241] (rows=143930993 width=455) + predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_51_date_dim_d_date_sk_min) AND DynamicValue(RS_51_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_51_date_dim_d_date_sk_bloom_filter))) and ws_bill_customer_sk is not null and ws_sold_date_sk is not null) + TableScan [TS_41] (rows=144002668 width=455) + default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_customer_sk","ws_ext_discount_amt","ws_ext_sales_price","ws_ext_wholesale_cost","ws_ext_list_price"] + <-Reducer 36 [BROADCAST_EDGE] vectorized + BROADCAST [RS_528] + Group By Operator [GBY_527] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_503] + Group By Operator [GBY_497] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_490] (rows=652 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_479] <-Reducer 5 [ONE_TO_ONE_EDGE] - FORWARD [RS_132] + FORWARD [RS_126] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_474] (rows=31888273 width=324) - Conds:RS_526._col0=RS_536._col0(Inner),Output:["_col1","_col2","_col3"] + Merge Join Operator [MERGEJOIN_468] (rows=31888273 width=324) + Conds:RS_518._col0=RS_526._col0(Inner),Output:["_col1","_col2","_col3"] <-Reducer 14 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_536] + SHUFFLE [RS_526] PartitionCols:_col0 - Select Operator [SEL_535] (rows=26666666 width=212) + Select Operator [SEL_525] (rows=26666666 width=212) Output:["_col0","_col1"] - Filter Operator [FIL_534] (rows=26666666 width=212) + Filter Operator [FIL_524] (rows=26666666 width=212) predicate:(_col7 > 0) - Select Operator [SEL_533] (rows=80000000 width=212) + Select Operator [SEL_523] (rows=80000000 width=212) Output:["_col0","_col7"] - Group By Operator [GBY_532] (rows=80000000 width=764) + Group By Operator [GBY_522] (rows=80000000 width=764) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4, KEY._col5, KEY._col6 <-Reducer 13 [SIMPLE_EDGE] - SHUFFLE [RS_39] + SHUFFLE [RS_37] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Group By Operator [GBY_38] (rows=80000000 width=764) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col7)"],keys:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Select Operator [SEL_36] (rows=187573258 width=1043) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] - Merge Join Operator [MERGEJOIN_465] (rows=187573258 width=1043) - Conds:RS_33._col1=RS_521._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9","_col10","_col11","_col12","_col13","_col14","_col15"] - <-Map 38 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_521] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_517] - <-Reducer 12 [SIMPLE_EDGE] - SHUFFLE [RS_33] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_464] (rows=187573258 width=395) - Conds:RS_531._col0=RS_493._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"] - <-Map 31 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_493] - PartitionCols:_col0 - Select Operator [SEL_484] (rows=652 width=8) - Output:["_col0"] - Filter Operator [FIL_480] (rows=652 width=8) - predicate:((d_year = 2001) and d_date_sk is not null) - Please refer to the previous TableScan [TS_111] - <-Map 11 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_531] - PartitionCols:_col0 - Select Operator [SEL_530] (rows=525327388 width=435) - Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_529] (rows=525327388 width=435) - predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_31_date_dim_d_date_sk_min) AND DynamicValue(RS_31_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_31_date_dim_d_date_sk_bloom_filter))) and ss_customer_sk is not null and ss_sold_date_sk is not null) - TableScan [TS_21] (rows=575995635 width=435) - default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_customer_sk","ss_ext_discount_amt","ss_ext_sales_price","ss_ext_wholesale_cost","ss_ext_list_price"] - <-Reducer 35 [BROADCAST_EDGE] vectorized - BROADCAST [RS_528] - Group By Operator [GBY_527] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_508] - Group By Operator [GBY_502] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_494] (rows=652 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_484] + Group By Operator [GBY_36] (rows=80000000 width=764) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col2)"],keys:_col5, _col6, _col7, _col8, _col9, _col10, _col11 + Merge Join Operator [MERGEJOIN_459] (rows=187573258 width=764) + Conds:RS_32._col1=RS_513._col0(Inner),Output:["_col2","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] + <-Map 38 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_513] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_509] + <-Reducer 12 [SIMPLE_EDGE] + SHUFFLE [RS_32] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_458] (rows=187573258 width=115) + Conds:RS_29._col0=RS_487._col0(Inner),Output:["_col1","_col2"] + <-Map 31 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_487] + PartitionCols:_col0 + Select Operator [SEL_478] (rows=652 width=4) + Output:["_col0"] + Filter Operator [FIL_474] (rows=652 width=8) + predicate:((d_year = 2001) and d_date_sk is not null) + Please refer to the previous TableScan [TS_106] + <-Map 11 [SIMPLE_EDGE] + SHUFFLE [RS_29] + PartitionCols:_col0 + Select Operator [SEL_22] (rows=525327388 width=119) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_238] (rows=525327388 width=435) + predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_30_date_dim_d_date_sk_min) AND DynamicValue(RS_30_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_30_date_dim_d_date_sk_bloom_filter))) and ss_customer_sk is not null and ss_sold_date_sk is not null) + TableScan [TS_20] (rows=575995635 width=435) + default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_customer_sk","ss_ext_discount_amt","ss_ext_sales_price","ss_ext_wholesale_cost","ss_ext_list_price"] + <-Reducer 35 [BROADCAST_EDGE] vectorized + BROADCAST [RS_520] + Group By Operator [GBY_519] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_502] + Group By Operator [GBY_496] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_488] (rows=652 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_478] <-Reducer 4 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_526] + SHUFFLE [RS_518] PartitionCols:_col0 - Select Operator [SEL_525] (rows=51391963 width=212) + Select Operator [SEL_517] (rows=51391963 width=212) Output:["_col0","_col1"] - Group By Operator [GBY_524] (rows=51391963 width=764) + Group By Operator [GBY_516] (rows=51391963 width=764) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4, KEY._col5, KEY._col6 <-Reducer 3 [SIMPLE_EDGE] - SHUFFLE [RS_18] + SHUFFLE [RS_17] PartitionCols:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Group By Operator [GBY_17] (rows=51391963 width=764) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col7)"],keys:_col0, _col1, _col2, _col3, _col4, _col5, _col6 - Select Operator [SEL_15] (rows=51391963 width=1099) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] - Merge Join Operator [MERGEJOIN_463] (rows=51391963 width=1099) - Conds:RS_12._col1=RS_520._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9","_col10","_col11","_col12","_col13","_col14","_col15"] - <-Map 38 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_520] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_517] - <-Reducer 2 [SIMPLE_EDGE] - SHUFFLE [RS_12] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_462] (rows=51391963 width=451) - Conds:RS_515._col0=RS_491._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"] - <-Map 31 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_491] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_483] - <-Map 1 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_515] - PartitionCols:_col0 - Select Operator [SEL_514] (rows=143930993 width=455) - Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_513] (rows=143930993 width=455) - predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_10_date_dim_d_date_sk_min) AND DynamicValue(RS_10_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_10_date_dim_d_date_sk_bloom_filter))) and ws_bill_customer_sk is not null and ws_sold_date_sk is not null) - TableScan [TS_0] (rows=144002668 width=455) - default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_customer_sk","ws_ext_discount_amt","ws_ext_sales_price","ws_ext_wholesale_cost","ws_ext_list_price"] - <-Reducer 34 [BROADCAST_EDGE] vectorized - BROADCAST [RS_512] - Group By Operator [GBY_511] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_507] - Group By Operator [GBY_501] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_492] (rows=652 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_483] + Group By Operator [GBY_16] (rows=51391963 width=764) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"],aggregations:["sum(_col2)"],keys:_col5, _col6, _col7, _col8, _col9, _col10, _col11 + Merge Join Operator [MERGEJOIN_457] (rows=51391963 width=764) + Conds:RS_12._col1=RS_512._col0(Inner),Output:["_col2","_col5","_col6","_col7","_col8","_col9","_col10","_col11"] + <-Map 38 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_512] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_509] + <-Reducer 2 [SIMPLE_EDGE] + SHUFFLE [RS_12] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_456] (rows=51391963 width=115) + Conds:RS_9._col0=RS_485._col0(Inner),Output:["_col1","_col2"] + <-Map 31 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_485] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_477] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_9] + PartitionCols:_col0 + Select Operator [SEL_2] (rows=143930993 width=119) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_235] (rows=143930993 width=455) + predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_10_date_dim_d_date_sk_min) AND DynamicValue(RS_10_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_10_date_dim_d_date_sk_bloom_filter))) and ws_bill_customer_sk is not null and ws_sold_date_sk is not null) + TableScan [TS_0] (rows=144002668 width=455) + default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_customer_sk","ws_ext_discount_amt","ws_ext_sales_price","ws_ext_wholesale_cost","ws_ext_list_price"] + <-Reducer 34 [BROADCAST_EDGE] vectorized + BROADCAST [RS_506] + Group By Operator [GBY_505] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 31 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_501] + Group By Operator [GBY_495] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_486] (rows=652 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_477]
http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query40.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query40.q.out b/ql/src/test/results/clientpositive/perf/tez/query40.q.out index 1cca18d..6e566e1 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query40.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query40.q.out @@ -96,12 +96,12 @@ Stage-0 PartitionCols:_col0, _col1 Group By Operator [GBY_29] (rows=5757278 width=410) Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(_col2)","sum(_col3)"],keys:_col0, _col1 - Top N Key Operator [TNK_55] (rows=5757278 width=364) + Top N Key Operator [TNK_55] (rows=5757278 width=278) keys:_col0, _col1,sort order:++,top n:100 - Select Operator [SEL_27] (rows=5757278 width=364) + Select Operator [SEL_27] (rows=5757278 width=278) Output:["_col0","_col1","_col2","_col3"] - Merge Join Operator [MERGEJOIN_101] (rows=5757278 width=364) - Conds:RS_24._col1=RS_126._col0(Inner),Output:["_col4","_col7","_col9","_col11","_col14"] + Merge Join Operator [MERGEJOIN_101] (rows=5757278 width=278) + Conds:RS_24._col1=RS_126._col0(Inner),Output:["_col4","_col7","_col9","_col10","_col12","_col14"] <-Map 13 [SIMPLE_EDGE] vectorized SHUFFLE [RS_126] PartitionCols:_col0 @@ -114,12 +114,12 @@ Stage-0 <-Reducer 4 [SIMPLE_EDGE] SHUFFLE [RS_24] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_100] (rows=5757278 width=281) - Conds:RS_21._col2=RS_112._col0(Inner),Output:["_col1","_col4","_col7","_col9","_col11"] + Merge Join Operator [MERGEJOIN_100] (rows=5757278 width=195) + Conds:RS_21._col2=RS_112._col0(Inner),Output:["_col1","_col4","_col7","_col9","_col10","_col12"] <-Map 11 [SIMPLE_EDGE] vectorized SHUFFLE [RS_112] PartitionCols:_col0 - Select Operator [SEL_111] (rows=51333 width=215) + Select Operator [SEL_111] (rows=51333 width=104) Output:["_col0","_col1"] Filter Operator [FIL_110] (rows=51333 width=215) predicate:(i_current_price BETWEEN 0.99 AND 1.49 and i_item_sk is not null) @@ -128,13 +128,13 @@ Stage-0 <-Reducer 3 [SIMPLE_EDGE] SHUFFLE [RS_21] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_99] (rows=51815831 width=210) - Conds:RS_18._col0=RS_104._col0(Inner),Output:["_col1","_col2","_col4","_col7","_col9"] + Merge Join Operator [MERGEJOIN_99] (rows=51815831 width=124) + Conds:RS_18._col0=RS_104._col0(Inner),Output:["_col1","_col2","_col4","_col7","_col9","_col10"] <-Map 9 [SIMPLE_EDGE] vectorized SHUFFLE [RS_104] PartitionCols:_col0 - Select Operator [SEL_103] (rows=8116 width=98) - Output:["_col0","_col1"] + Select Operator [SEL_103] (rows=8116 width=12) + Output:["_col0","_col1","_col2"] Filter Operator [FIL_102] (rows=8116 width=98) predicate:(CAST( d_date AS TIMESTAMP) BETWEEN TIMESTAMP'1998-03-09 00:00:00' AND TIMESTAMP'1998-05-08 00:00:00' and d_date_sk is not null) TableScan [TS_6] (rows=73049 width=98) http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query42.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query42.q.out b/ql/src/test/results/clientpositive/perf/tez/query42.q.out index a458f5e..0a01d71 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query42.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query42.q.out @@ -79,13 +79,13 @@ Stage-0 SHUFFLE [RS_17] PartitionCols:_col0, _col1 Group By Operator [GBY_16] (rows=120 width=206) - Output:["_col0","_col1","_col2"],aggregations:["sum(_col2)"],keys:_col7, _col8 + Output:["_col0","_col1","_col2"],aggregations:["sum(_col2)"],keys:_col5, _col6 Merge Join Operator [MERGEJOIN_54] (rows=2301098 width=94) - Conds:RS_12._col1=RS_65._col0(Inner),Output:["_col2","_col7","_col8"] + Conds:RS_12._col1=RS_65._col0(Inner),Output:["_col2","_col5","_col6"] <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_65] PartitionCols:_col0 - Select Operator [SEL_64] (rows=7333 width=101) + Select Operator [SEL_64] (rows=7333 width=97) Output:["_col0","_col1","_col2"] Filter Operator [FIL_63] (rows=7333 width=101) predicate:((i_manager_id = 1) and i_item_sk is not null) @@ -99,7 +99,7 @@ Stage-0 <-Map 6 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_57] PartitionCols:_col0 - Select Operator [SEL_56] (rows=50 width=12) + Select Operator [SEL_56] (rows=50 width=4) Output:["_col0"] Filter Operator [FIL_55] (rows=50 width=12) predicate:((d_moy = 12) and (d_year = 1998) and d_date_sk is not null) http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query43.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query43.q.out b/ql/src/test/results/clientpositive/perf/tez/query43.q.out index f75929b..66ded7d 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query43.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query43.q.out @@ -70,18 +70,18 @@ Stage-0 <-Reducer 3 [SIMPLE_EDGE] SHUFFLE [RS_18] PartitionCols:_col0, _col1 - Group By Operator [GBY_17] (rows=176297 width=972) + Group By Operator [GBY_17] (rows=142538 width=972) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8"],aggregations:["sum(_col2)","sum(_col3)","sum(_col4)","sum(_col5)","sum(_col6)","sum(_col7)","sum(_col8)"],keys:_col0, _col1 - Top N Key Operator [TNK_33] (rows=37536846 width=320) + Top N Key Operator [TNK_33] (rows=37536846 width=257) keys:_col0, _col1,sort order:++,top n:100 - Select Operator [SEL_15] (rows=37536846 width=320) + Select Operator [SEL_15] (rows=37536846 width=257) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8"] - Merge Join Operator [MERGEJOIN_55] (rows=37536846 width=320) - Conds:RS_12._col1=RS_66._col0(Inner),Output:["_col2","_col5","_col7","_col8"] + Merge Join Operator [MERGEJOIN_55] (rows=37536846 width=257) + Conds:RS_12._col1=RS_66._col0(Inner),Output:["_col2","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col12","_col13"] <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_66] PartitionCols:_col0 - Select Operator [SEL_65] (rows=341 width=304) + Select Operator [SEL_65] (rows=341 width=192) Output:["_col0","_col1","_col2"] Filter Operator [FIL_64] (rows=341 width=303) predicate:((s_gmt_offset = -6) and s_store_sk is not null) @@ -90,13 +90,13 @@ Stage-0 <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_12] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_54] (rows=187574154 width=192) - Conds:RS_74._col0=RS_58._col0(Inner),Output:["_col1","_col2","_col5"] + Merge Join Operator [MERGEJOIN_54] (rows=187574154 width=129) + Conds:RS_74._col0=RS_58._col0(Inner),Output:["_col1","_col2","_col4","_col5","_col6","_col7","_col8","_col9","_col10"] <-Map 6 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_58] PartitionCols:_col0 - Select Operator [SEL_57] (rows=652 width=99) - Output:["_col0","_col2"] + Select Operator [SEL_57] (rows=652 width=32) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] Filter Operator [FIL_56] (rows=652 width=99) predicate:((d_year = 1998) and d_date_sk is not null) TableScan [TS_3] (rows=73049 width=99) http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query46.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query46.q.out b/ql/src/test/results/clientpositive/perf/tez/query46.q.out index 378741b..7b0d0a6 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query46.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query46.q.out @@ -148,9 +148,9 @@ Stage-0 SHUFFLE [RS_35] PartitionCols:_col0, _col1, _col2, _col3 Group By Operator [GBY_34] (rows=8380115 width=321) - Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["sum(_col6)","sum(_col7)"],keys:_col1, _col17, _col3, _col5 + Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["sum(_col6)","sum(_col7)"],keys:_col1, _col12, _col3, _col5 Merge Join Operator [MERGEJOIN_144] (rows=8380115 width=97) - Conds:RS_30._col3=RS_152._col0(Inner),Output:["_col1","_col3","_col5","_col6","_col7","_col17"] + Conds:RS_30._col3=RS_152._col0(Inner),Output:["_col1","_col3","_col5","_col6","_col7","_col12"] <-Map 5 [SIMPLE_EDGE] vectorized SHUFFLE [RS_152] PartitionCols:_col0 @@ -163,7 +163,7 @@ Stage-0 <-Map 16 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_171] PartitionCols:_col0 - Select Operator [SEL_170] (rows=1855 width=12) + Select Operator [SEL_170] (rows=1855 width=4) Output:["_col0"] Filter Operator [FIL_169] (rows=1855 width=12) predicate:(((hd_dep_count = 2) or (hd_vehicle_count = 1)) and hd_demo_sk is not null) @@ -177,7 +177,7 @@ Stage-0 <-Map 14 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_163] PartitionCols:_col0 - Select Operator [SEL_162] (rows=35 width=97) + Select Operator [SEL_162] (rows=35 width=4) Output:["_col0"] Filter Operator [FIL_161] (rows=35 width=97) predicate:((s_city) IN ('Cedar Grove', 'Wildwood', 'Union', 'Salem', 'Highland Park') and s_store_sk is not null) @@ -191,7 +191,7 @@ Stage-0 <-Map 12 [SIMPLE_EDGE] vectorized SHUFFLE [RS_155] PartitionCols:_col0 - Select Operator [SEL_154] (rows=783 width=12) + Select Operator [SEL_154] (rows=783 width=4) Output:["_col0"] Filter Operator [FIL_153] (rows=783 width=12) predicate:((d_dow) IN (6, 0) and (d_year) IN (1998, 1999, 2000) and d_date_sk is not null) http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query47.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query47.q.out b/ql/src/test/results/clientpositive/perf/tez/query47.q.out index 75ab317..04c64b4 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query47.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query47.q.out @@ -139,10 +139,10 @@ Stage-0 Select Operator [SEL_109] (rows=241454 width=658) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] Merge Join Operator [MERGEJOIN_278] (rows=241454 width=546) - Conds:RS_106._col6, _col7, _col8, _col9, _col14=RS_306._col0, _col1, _col2, _col3, (_col5 - 1)(Inner),Output:["_col4","_col6","_col10","_col11","_col12","_col13","_col19"] + Conds:RS_106._col6, _col7, _col8, _col9, _col14=RS_306._col0, _col1, _col2, _col3, _col5(Inner),Output:["_col4","_col6","_col10","_col11","_col12","_col13","_col19"] <-Reducer 6 [SIMPLE_EDGE] vectorized SHUFFLE [RS_306] - PartitionCols:_col0, _col1, _col2, _col3, (_col5 - 1) + PartitionCols:_col0, _col1, _col2, _col3, _col5 Select Operator [SEL_304] (rows=162257387 width=485) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] Filter Operator [FIL_302] (rows=162257387 width=489) @@ -224,10 +224,10 @@ Stage-0 FORWARD [RS_106] PartitionCols:_col6, _col7, _col8, _col9, _col14 Merge Join Operator [MERGEJOIN_277] (rows=241454 width=717) - Conds:RS_307._col0, _col1, _col2, _col3, (_col5 + 1)=RS_318._col0, _col1, _col2, _col3, _col8(Inner),Output:["_col4","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14"] + Conds:RS_307._col0, _col1, _col2, _col3, _col5=RS_318._col0, _col1, _col2, _col3, _col8(Inner),Output:["_col4","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col14"] <-Reducer 6 [SIMPLE_EDGE] vectorized SHUFFLE [RS_307] - PartitionCols:_col0, _col1, _col2, _col3, (_col5 + 1) + PartitionCols:_col0, _col1, _col2, _col3, _col5 Select Operator [SEL_305] (rows=162257387 width=485) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] Filter Operator [FIL_303] (rows=162257387 width=489)
