http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query27.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query27.q.out b/ql/src/test/results/clientpositive/perf/tez/query27.q.out index 59cca4f..d7fd2ed 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query27.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query27.q.out @@ -94,7 +94,7 @@ Stage-0 Select Operator [SEL_27] (rows=1427275 width=186) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] Merge Join Operator [MERGEJOIN_100] (rows=1427275 width=186) - Conds:RS_24._col1=RS_130._col0(Inner),Output:["_col4","_col5","_col6","_col7","_col15","_col17"] + Conds:RS_24._col1=RS_130._col0(Inner),Output:["_col4","_col5","_col6","_col7","_col11","_col13"] <-Map 14 [SIMPLE_EDGE] vectorized SHUFFLE [RS_130] PartitionCols:_col0 @@ -108,7 +108,7 @@ Stage-0 SHUFFLE [RS_24] PartitionCols:_col1 Merge Join Operator [MERGEJOIN_99] (rows=1427275 width=90) - Conds:RS_21._col3=RS_119._col0(Inner),Output:["_col1","_col4","_col5","_col6","_col7","_col15"] + Conds:RS_21._col3=RS_119._col0(Inner),Output:["_col1","_col4","_col5","_col6","_col7","_col11"] <-Map 12 [SIMPLE_EDGE] vectorized SHUFFLE [RS_119] PartitionCols:_col0 @@ -126,7 +126,7 @@ Stage-0 <-Map 10 [SIMPLE_EDGE] vectorized SHUFFLE [RS_111] PartitionCols:_col0 - Select Operator [SEL_110] (rows=652 width=8) + Select Operator [SEL_110] (rows=652 width=4) Output:["_col0"] Filter Operator [FIL_109] (rows=652 width=8) predicate:((d_year = 2001) and d_date_sk is not null) @@ -140,7 +140,7 @@ Stage-0 <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_103] PartitionCols:_col0 - Select Operator [SEL_102] (rows=14776 width=269) + Select Operator [SEL_102] (rows=14776 width=4) Output:["_col0"] Filter Operator [FIL_101] (rows=14776 width=268) predicate:((cd_education_status = '2 yr Degree') and (cd_gender = 'M') and (cd_marital_status = 'U') and cd_demo_sk is not null)
http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query29.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query29.q.out b/ql/src/test/results/clientpositive/perf/tez/query29.q.out index a21c3c7..19f121e 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query29.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query29.q.out @@ -144,20 +144,20 @@ Stage-0 SHUFFLE [RS_49] PartitionCols:_col0, _col1, _col2, _col3 Group By Operator [GBY_48] (rows=21091879 width=496) - Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["sum(_col14)","sum(_col22)","sum(_col3)"],keys:_col7, _col8, _col27, _col28 + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["sum(_col13)","sum(_col19)","sum(_col3)"],keys:_col6, _col7, _col22, _col23 Top N Key Operator [TNK_93] (rows=4156223234 width=483) - keys:_col7, _col8, _col27, _col28,sort order:++++,top n:100 + keys:_col6, _col7, _col22, _col23,sort order:++++,top n:100 Merge Join Operator [MERGEJOIN_205] (rows=4156223234 width=483) - Conds:RS_44._col1, _col2=RS_45._col14, _col13(Inner),Output:["_col3","_col7","_col8","_col14","_col22","_col27","_col28"] + Conds:RS_44._col2, _col1=RS_45._col11, _col12(Inner),Output:["_col3","_col6","_col7","_col13","_col19","_col22","_col23"] <-Reducer 2 [SIMPLE_EDGE] PARTITION_ONLY_SHUFFLE [RS_44] - PartitionCols:_col1, _col2 + PartitionCols:_col2, _col1 Merge Join Operator [MERGEJOIN_199] (rows=7638375 width=10) Conds:RS_216._col0=RS_208._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_208] PartitionCols:_col0 - Select Operator [SEL_207] (rows=1957 width=8) + Select Operator [SEL_207] (rows=1957 width=4) Output:["_col0"] Filter Operator [FIL_206] (rows=1957 width=8) predicate:((d_year) IN (1999, 2000, 2001) and d_date_sk is not null) @@ -185,11 +185,11 @@ Stage-0 Please refer to the previous Select Operator [SEL_207] <-Reducer 14 [SIMPLE_EDGE] SHUFFLE [RS_45] - PartitionCols:_col14, _col13 + PartitionCols:_col11, _col12 Select Operator [SEL_40] (rows=21091879 width=484) - Output:["_col1","_col2","_col8","_col13","_col14","_col16","_col21","_col22"] + Output:["_col1","_col2","_col8","_col11","_col12","_col14","_col17","_col18"] Merge Join Operator [MERGEJOIN_204] (rows=21091879 width=484) - Conds:RS_37._col3=RS_249._col0(Inner),Output:["_col5","_col10","_col11","_col13","_col18","_col19","_col21","_col22"] + Conds:RS_37._col3=RS_249._col0(Inner),Output:["_col5","_col8","_col9","_col11","_col14","_col15","_col17","_col18"] <-Map 23 [SIMPLE_EDGE] vectorized SHUFFLE [RS_249] PartitionCols:_col0 @@ -203,7 +203,7 @@ Stage-0 SHUFFLE [RS_37] PartitionCols:_col3 Merge Join Operator [MERGEJOIN_203] (rows=21091879 width=298) - Conds:RS_34._col1=RS_246._col0(Inner),Output:["_col3","_col5","_col10","_col11","_col13","_col18","_col19"] + Conds:RS_34._col1=RS_246._col0(Inner),Output:["_col3","_col5","_col8","_col9","_col11","_col14","_col15"] <-Map 22 [SIMPLE_EDGE] vectorized SHUFFLE [RS_246] PartitionCols:_col0 @@ -217,7 +217,7 @@ Stage-0 SHUFFLE [RS_34] PartitionCols:_col1 Merge Join Operator [MERGEJOIN_202] (rows=21091879 width=18) - Conds:RS_31._col1, _col2, _col4=RS_32._col1, _col2, _col3(Inner),Output:["_col1","_col3","_col5","_col10","_col11","_col13"] + Conds:RS_31._col1, _col2, _col4=RS_32._col1, _col2, _col3(Inner),Output:["_col1","_col3","_col5","_col8","_col9","_col11"] <-Reducer 17 [SIMPLE_EDGE] PARTITION_ONLY_SHUFFLE [RS_32] PartitionCols:_col1, _col2, _col3 @@ -226,7 +226,7 @@ Stage-0 <-Map 15 [SIMPLE_EDGE] vectorized SHUFFLE [RS_223] PartitionCols:_col0 - Select Operator [SEL_220] (rows=201 width=12) + Select Operator [SEL_220] (rows=201 width=4) Output:["_col0"] Filter Operator [FIL_218] (rows=201 width=12) predicate:((d_year = 1999) and d_date_sk is not null and d_moy BETWEEN 4 AND 7) @@ -249,7 +249,7 @@ Stage-0 <-Map 15 [SIMPLE_EDGE] vectorized SHUFFLE [RS_221] PartitionCols:_col0 - Select Operator [SEL_219] (rows=50 width=12) + Select Operator [SEL_219] (rows=50 width=4) Output:["_col0"] Filter Operator [FIL_217] (rows=50 width=12) predicate:((d_moy = 4) and (d_year = 1999) and d_date_sk is not null) @@ -315,7 +315,7 @@ Stage-0 PARTITION_ONLY_SHUFFLE [RS_146] Group By Operator [GBY_145] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_144] (rows=7638375 width=6) + Select Operator [SEL_144] (rows=7638375 width=8) Output:["_col0"] Please refer to the previous Merge Join Operator [MERGEJOIN_199] <-Reducer 7 [BROADCAST_EDGE] vectorized @@ -326,7 +326,7 @@ Stage-0 PARTITION_ONLY_SHUFFLE [RS_151] Group By Operator [GBY_150] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_149] (rows=7638375 width=8) + Select Operator [SEL_149] (rows=7638375 width=6) Output:["_col0"] Please refer to the previous Merge Join Operator [MERGEJOIN_199] http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query3.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query3.q.out b/ql/src/test/results/clientpositive/perf/tez/query3.q.out index d4296cf..e31c994 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query3.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query3.q.out @@ -75,13 +75,13 @@ Stage-0 SHUFFLE [RS_17] PartitionCols:_col0, _col1, _col2 Group By Operator [GBY_16] (rows=274400 width=220) - Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(_col2)"],keys:_col8, _col4, _col5 + Output:["_col0","_col1","_col2","_col3"],aggregations:["sum(_col2)"],keys:_col7, _col4, _col5 Merge Join Operator [MERGEJOIN_53] (rows=589741 width=108) - Conds:RS_12._col0=RS_64._col0(Inner),Output:["_col2","_col4","_col5","_col8"] + Conds:RS_12._col0=RS_64._col0(Inner),Output:["_col2","_col4","_col5","_col7"] <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_64] PartitionCols:_col0 - Select Operator [SEL_63] (rows=5619 width=12) + Select Operator [SEL_63] (rows=5619 width=8) Output:["_col0","_col1"] Filter Operator [FIL_62] (rows=5619 width=12) predicate:((d_moy = 12) and d_date_sk is not null) @@ -95,7 +95,7 @@ Stage-0 <-Map 6 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_56] PartitionCols:_col0 - Select Operator [SEL_55] (rows=669 width=111) + Select Operator [SEL_55] (rows=669 width=107) Output:["_col0","_col1","_col2"] Filter Operator [FIL_54] (rows=669 width=111) predicate:((i_manufact_id = 436) and i_item_sk is not null) http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query30.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query30.q.out b/ql/src/test/results/clientpositive/perf/tez/query30.q.out index 9f9559e..d3381b3 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query30.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query30.q.out @@ -97,7 +97,7 @@ Stage-0 Select Operator [SEL_62] (rows=691171 width=942) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12"] Merge Join Operator [MERGEJOIN_177] (rows=691171 width=942) - Conds:RS_59._col0=RS_60._col0(Inner),Output:["_col1","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col18"] + Conds:RS_59._col0=RS_60._col0(Inner),Output:["_col1","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10","_col11","_col12","_col13","_col17"] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_59] PartitionCols:_col0 @@ -106,7 +106,7 @@ Stage-0 <-Map 5 [SIMPLE_EDGE] vectorized SHUFFLE [RS_187] PartitionCols:_col0 - Select Operator [SEL_184] (rows=784314 width=90) + Select Operator [SEL_184] (rows=784314 width=4) Output:["_col0"] Filter Operator [FIL_181] (rows=784314 width=90) predicate:((ca_state = 'IL') and ca_address_sk is not null) @@ -145,9 +145,9 @@ Stage-0 SHUFFLE [RS_43] PartitionCols:_col0 Group By Operator [GBY_42] (rows=3923529 width=201) - Output:["_col0","_col1","_col2"],aggregations:["sum(_col3)"],keys:_col7, _col1 + Output:["_col0","_col1","_col2"],aggregations:["sum(_col3)"],keys:_col6, _col1 Merge Join Operator [MERGEJOIN_175] (rows=3923529 width=184) - Conds:RS_38._col2=RS_189._col0(Inner),Output:["_col1","_col3","_col7"] + Conds:RS_38._col2=RS_189._col0(Inner),Output:["_col1","_col3","_col6"] <-Map 5 [SIMPLE_EDGE] vectorized SHUFFLE [RS_189] PartitionCols:_col0 @@ -173,7 +173,7 @@ Stage-0 <-Map 14 [SIMPLE_EDGE] vectorized SHUFFLE [RS_199] PartitionCols:_col0 - Select Operator [SEL_197] (rows=652 width=8) + Select Operator [SEL_197] (rows=652 width=4) Output:["_col0"] Filter Operator [FIL_196] (rows=652 width=8) predicate:((d_year = 2002) and d_date_sk is not null) @@ -190,9 +190,9 @@ Stage-0 SHUFFLE [RS_23] PartitionCols:_col0, _col1 Group By Operator [GBY_22] (rows=3746772 width=201) - Output:["_col0","_col1","_col2"],aggregations:["sum(_col3)"],keys:_col7, _col1 + Output:["_col0","_col1","_col2"],aggregations:["sum(_col3)"],keys:_col6, _col1 Merge Join Operator [MERGEJOIN_173] (rows=3746772 width=184) - Conds:RS_18._col2=RS_188._col0(Inner),Output:["_col1","_col3","_col7"] + Conds:RS_18._col2=RS_188._col0(Inner),Output:["_col1","_col3","_col6"] <-Map 5 [SIMPLE_EDGE] vectorized SHUFFLE [RS_188] PartitionCols:_col0 http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query31.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query31.q.out b/ql/src/test/results/clientpositive/perf/tez/query31.q.out index 32d06b6..c0762b7 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query31.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query31.q.out @@ -157,32 +157,32 @@ Stage-0 File Output Operator [FS_139] Select Operator [SEL_138] (rows=110 width=550) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_136] (rows=110 width=770) - predicate:(CASE WHEN ((_col1 > 0)) THEN (CASE WHEN ((_col9 > 0)) THEN (((_col11 / _col9) > (_col5 / _col1))) ELSE ((null > (_col5 / _col1))) END) ELSE (CASE WHEN ((_col9 > 0)) THEN (((_col11 / _col9) > null)) ELSE (null) END) END and CASE WHEN ((_col3 > 0)) THEN (CASE WHEN ((_col7 > 0)) THEN (((_col9 / _col7) > (_col1 / _col3))) ELSE ((null > (_col1 / _col3))) END) ELSE (CASE WHEN ((_col7 > 0)) THEN (((_col9 / _col7) > null)) ELSE (null) END) END) - Merge Join Operator [MERGEJOIN_450] (rows=440 width=770) - Conds:RS_133._col0=RS_134._col0(Inner),Output:["_col0","_col1","_col3","_col5","_col7","_col9","_col11"] + Filter Operator [FIL_136] (rows=110 width=778) + predicate:(CASE WHEN ((_col11 > 0)) THEN (CASE WHEN (_col2) THEN (((_col6 / _col1) > (_col9 / _col11))) ELSE ((null > (_col9 / _col11))) END) ELSE (CASE WHEN (_col2) THEN (((_col6 / _col1) > null)) ELSE (null) END) END and CASE WHEN ((_col9 > 0)) THEN (CASE WHEN (_col7) THEN (((_col4 / _col6) > (_col13 / _col9))) ELSE ((null > (_col13 / _col9))) END) ELSE (CASE WHEN (_col7) THEN (((_col4 / _col6) > null)) ELSE (null) END) END) + Merge Join Operator [MERGEJOIN_450] (rows=440 width=778) + Conds:RS_133._col0=RS_134._col0(Inner),Output:["_col1","_col2","_col4","_col6","_col7","_col8","_col9","_col11","_col13"] <-Reducer 22 [ONE_TO_ONE_EDGE] FORWARD [RS_134] PartitionCols:_col0 - Merge Join Operator [MERGEJOIN_449] (rows=440 width=434) - Conds:RS_123._col0=RS_536._col0(Inner),Output:["_col0","_col1","_col3","_col5"] + Merge Join Operator [MERGEJOIN_448] (rows=1605 width=434) + Conds:RS_123._col0=RS_538._col0(Inner),Output:["_col0","_col1","_col3","_col5"] <-Reducer 21 [ONE_TO_ONE_EDGE] FORWARD [RS_123] PartitionCols:_col0 - Merge Join Operator [MERGEJOIN_448] (rows=440 width=322) - Conds:RS_522._col0=RS_529._col0(Inner),Output:["_col0","_col1","_col3"] + Merge Join Operator [MERGEJOIN_447] (rows=1605 width=322) + Conds:RS_524._col0=RS_531._col0(Inner),Output:["_col0","_col1","_col3"] <-Reducer 20 [ONE_TO_ONE_EDGE] vectorized - FORWARD [RS_522] + FORWARD [RS_524] PartitionCols:_col0 - Group By Operator [GBY_521] (rows=440 width=210) + Group By Operator [GBY_523] (rows=1605 width=210) Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 <-Reducer 19 [SIMPLE_EDGE] SHUFFLE [RS_77] PartitionCols:_col0 - Group By Operator [GBY_76] (rows=3960 width=210) - Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_441] (rows=10246882 width=209) - Conds:RS_72._col1=RS_497._col0(Inner),Output:["_col2","_col7"] + Group By Operator [GBY_76] (rows=33705 width=210) + Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col5 + Merge Join Operator [MERGEJOIN_441] (rows=37399561 width=139) + Conds:RS_72._col1=RS_497._col0(Inner),Output:["_col2","_col5"] <-Map 32 [SIMPLE_EDGE] vectorized SHUFFLE [RS_497] PartitionCols:_col0 @@ -195,29 +195,29 @@ Stage-0 <-Reducer 18 [SIMPLE_EDGE] SHUFFLE [RS_72] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_440] (rows=10246882 width=115) - Conds:RS_520._col0=RS_469._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_440] (rows=37399561 width=42) + Conds:RS_522._col0=RS_469._col0(Inner),Output:["_col1","_col2"] <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_469] PartitionCols:_col0 - Select Operator [SEL_460] (rows=130 width=12) + Select Operator [SEL_460] (rows=130 width=4) Output:["_col0"] Filter Operator [FIL_454] (rows=130 width=12) - predicate:((d_qoy = 1) and (d_year = 2000) and d_date_sk is not null) + predicate:((d_qoy = 2) and (d_year = 2000) and d_date_sk is not null) TableScan [TS_3] (rows=73049 width=12) default@date_dim,date_dim,Tbl:COMPLETE,Col:COMPLETE,Output:["d_date_sk","d_year","d_qoy"] <-Map 35 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_520] + SHUFFLE [RS_522] PartitionCols:_col0 - Select Operator [SEL_519] (rows=143931246 width=119) + Select Operator [SEL_521] (rows=525327191 width=114) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_518] (rows=143931246 width=119) - predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_70_date_dim_d_date_sk_min) AND DynamicValue(RS_70_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_70_date_dim_d_date_sk_bloom_filter))) and ws_bill_addr_sk is not null and ws_sold_date_sk is not null) - TableScan [TS_60] (rows=144002668 width=119) - default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_addr_sk","ws_ext_sales_price"] + Filter Operator [FIL_520] (rows=525327191 width=114) + predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_70_date_dim_d_date_sk_min) AND DynamicValue(RS_70_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_70_date_dim_d_date_sk_bloom_filter))) and ss_addr_sk is not null and ss_sold_date_sk is not null) + TableScan [TS_60] (rows=575995635 width=114) + default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_addr_sk","ss_ext_sales_price"] <-Reducer 23 [BROADCAST_EDGE] vectorized - BROADCAST [RS_517] - Group By Operator [GBY_516] (rows=1 width=12) + BROADCAST [RS_519] + Group By Operator [GBY_518] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_484] @@ -227,17 +227,17 @@ Stage-0 Output:["_col0"] Please refer to the previous Select Operator [SEL_460] <-Reducer 26 [ONE_TO_ONE_EDGE] vectorized - FORWARD [RS_529] + FORWARD [RS_531] PartitionCols:_col0 - Group By Operator [GBY_528] (rows=440 width=210) + Group By Operator [GBY_530] (rows=1605 width=210) Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 <-Reducer 25 [SIMPLE_EDGE] SHUFFLE [RS_97] PartitionCols:_col0 - Group By Operator [GBY_96] (rows=3960 width=210) - Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_443] (rows=10246882 width=209) - Conds:RS_92._col1=RS_498._col0(Inner),Output:["_col2","_col7"] + Group By Operator [GBY_96] (rows=33705 width=210) + Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col5 + Merge Join Operator [MERGEJOIN_443] (rows=37399561 width=139) + Conds:RS_92._col1=RS_498._col0(Inner),Output:["_col2","_col5"] <-Map 32 [SIMPLE_EDGE] vectorized SHUFFLE [RS_498] PartitionCols:_col0 @@ -245,28 +245,28 @@ Stage-0 <-Reducer 24 [SIMPLE_EDGE] SHUFFLE [RS_92] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_442] (rows=10246882 width=115) - Conds:RS_527._col0=RS_471._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_442] (rows=37399561 width=42) + Conds:RS_529._col0=RS_471._col0(Inner),Output:["_col1","_col2"] <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_471] PartitionCols:_col0 - Select Operator [SEL_461] (rows=130 width=12) + Select Operator [SEL_461] (rows=130 width=4) Output:["_col0"] Filter Operator [FIL_455] (rows=130 width=12) - predicate:((d_qoy = 2) and (d_year = 2000) and d_date_sk is not null) + predicate:((d_qoy = 1) and (d_year = 2000) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] <-Map 36 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_527] + SHUFFLE [RS_529] PartitionCols:_col0 - Select Operator [SEL_526] (rows=143931246 width=119) + Select Operator [SEL_528] (rows=525327191 width=114) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_525] (rows=143931246 width=119) - predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_90_date_dim_d_date_sk_min) AND DynamicValue(RS_90_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_90_date_dim_d_date_sk_bloom_filter))) and ws_bill_addr_sk is not null and ws_sold_date_sk is not null) - TableScan [TS_80] (rows=144002668 width=119) - default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_addr_sk","ws_ext_sales_price"] + Filter Operator [FIL_527] (rows=525327191 width=114) + predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_90_date_dim_d_date_sk_min) AND DynamicValue(RS_90_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_90_date_dim_d_date_sk_bloom_filter))) and ss_addr_sk is not null and ss_sold_date_sk is not null) + TableScan [TS_80] (rows=575995635 width=114) + default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_addr_sk","ss_ext_sales_price"] <-Reducer 27 [BROADCAST_EDGE] vectorized - BROADCAST [RS_524] - Group By Operator [GBY_523] (rows=1 width=12) + BROADCAST [RS_526] + Group By Operator [GBY_525] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_485] @@ -276,17 +276,17 @@ Stage-0 Output:["_col0"] Please refer to the previous Select Operator [SEL_461] <-Reducer 30 [ONE_TO_ONE_EDGE] vectorized - FORWARD [RS_536] + FORWARD [RS_538] PartitionCols:_col0 - Group By Operator [GBY_535] (rows=440 width=210) + Group By Operator [GBY_537] (rows=1605 width=210) Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 <-Reducer 29 [SIMPLE_EDGE] SHUFFLE [RS_117] PartitionCols:_col0 - Group By Operator [GBY_116] (rows=3960 width=210) - Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_445] (rows=10246882 width=209) - Conds:RS_112._col1=RS_499._col0(Inner),Output:["_col2","_col7"] + Group By Operator [GBY_116] (rows=33705 width=210) + Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col5 + Merge Join Operator [MERGEJOIN_445] (rows=37399561 width=139) + Conds:RS_112._col1=RS_499._col0(Inner),Output:["_col2","_col5"] <-Map 32 [SIMPLE_EDGE] vectorized SHUFFLE [RS_499] PartitionCols:_col0 @@ -294,28 +294,28 @@ Stage-0 <-Reducer 28 [SIMPLE_EDGE] SHUFFLE [RS_112] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_444] (rows=10246882 width=115) - Conds:RS_534._col0=RS_473._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_444] (rows=37399561 width=42) + Conds:RS_536._col0=RS_473._col0(Inner),Output:["_col1","_col2"] <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_473] PartitionCols:_col0 - Select Operator [SEL_462] (rows=130 width=12) + Select Operator [SEL_462] (rows=130 width=4) Output:["_col0"] Filter Operator [FIL_456] (rows=130 width=12) predicate:((d_qoy = 3) and (d_year = 2000) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] <-Map 37 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_534] + SHUFFLE [RS_536] PartitionCols:_col0 - Select Operator [SEL_533] (rows=143931246 width=119) + Select Operator [SEL_535] (rows=525327191 width=114) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_532] (rows=143931246 width=119) - predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_110_date_dim_d_date_sk_min) AND DynamicValue(RS_110_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_110_date_dim_d_date_sk_bloom_filter))) and ws_bill_addr_sk is not null and ws_sold_date_sk is not null) - TableScan [TS_100] (rows=144002668 width=119) - default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_addr_sk","ws_ext_sales_price"] + Filter Operator [FIL_534] (rows=525327191 width=114) + predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_110_date_dim_d_date_sk_min) AND DynamicValue(RS_110_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_110_date_dim_d_date_sk_bloom_filter))) and ss_addr_sk is not null and ss_sold_date_sk is not null) + TableScan [TS_100] (rows=575995635 width=114) + default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_addr_sk","ss_ext_sales_price"] <-Reducer 31 [BROADCAST_EDGE] vectorized - BROADCAST [RS_531] - Group By Operator [GBY_530] (rows=1 width=12) + BROADCAST [RS_533] + Group By Operator [GBY_532] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_486] @@ -327,74 +327,76 @@ Stage-0 <-Reducer 6 [ONE_TO_ONE_EDGE] FORWARD [RS_133] PartitionCols:_col0 - Merge Join Operator [MERGEJOIN_447] (rows=1605 width=434) - Conds:RS_130._col0=RS_515._col0(Inner),Output:["_col0","_col1","_col3","_col5"] + Merge Join Operator [MERGEJOIN_449] (rows=440 width=442) + Conds:RS_130._col0=RS_517._col0(Inner),Output:["_col0","_col1","_col2","_col4","_col6","_col7"] <-Reducer 16 [ONE_TO_ONE_EDGE] vectorized - FORWARD [RS_515] + FORWARD [RS_517] PartitionCols:_col0 - Group By Operator [GBY_514] (rows=1605 width=210) - Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 - <-Reducer 15 [SIMPLE_EDGE] - SHUFFLE [RS_57] - PartitionCols:_col0 - Group By Operator [GBY_56] (rows=33705 width=210) - Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_439] (rows=37399561 width=139) - Conds:RS_52._col1=RS_496._col0(Inner),Output:["_col2","_col7"] - <-Map 32 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_496] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_493] - <-Reducer 14 [SIMPLE_EDGE] - SHUFFLE [RS_52] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_438] (rows=37399561 width=42) - Conds:RS_513._col0=RS_467._col0(Inner),Output:["_col1","_col2"] - <-Map 8 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_467] - PartitionCols:_col0 - Select Operator [SEL_459] (rows=130 width=12) - Output:["_col0"] - Filter Operator [FIL_453] (rows=130 width=12) - predicate:((d_qoy = 3) and (d_year = 2000) and d_date_sk is not null) - Please refer to the previous TableScan [TS_3] - <-Map 34 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_513] - PartitionCols:_col0 - Select Operator [SEL_512] (rows=525327191 width=114) - Output:["_col0","_col1","_col2"] - Filter Operator [FIL_511] (rows=525327191 width=114) - predicate:((ss_sold_date_sk BETWEEN DynamicValue(RS_50_date_dim_d_date_sk_min) AND DynamicValue(RS_50_date_dim_d_date_sk_max) and in_bloom_filter(ss_sold_date_sk, DynamicValue(RS_50_date_dim_d_date_sk_bloom_filter))) and ss_addr_sk is not null and ss_sold_date_sk is not null) - TableScan [TS_40] (rows=575995635 width=114) - default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_addr_sk","ss_ext_sales_price"] - <-Reducer 17 [BROADCAST_EDGE] vectorized - BROADCAST [RS_510] - Group By Operator [GBY_509] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_483] - Group By Operator [GBY_477] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_468] (rows=130 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_459] + Select Operator [SEL_516] (rows=440 width=214) + Output:["_col0","_col1","_col2"] + Group By Operator [GBY_515] (rows=440 width=210) + Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 + <-Reducer 15 [SIMPLE_EDGE] + SHUFFLE [RS_57] + PartitionCols:_col0 + Group By Operator [GBY_56] (rows=3960 width=210) + Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col5 + Merge Join Operator [MERGEJOIN_439] (rows=10246882 width=209) + Conds:RS_52._col1=RS_496._col0(Inner),Output:["_col2","_col5"] + <-Map 32 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_496] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_493] + <-Reducer 14 [SIMPLE_EDGE] + SHUFFLE [RS_52] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_438] (rows=10246882 width=115) + Conds:RS_514._col0=RS_467._col0(Inner),Output:["_col1","_col2"] + <-Map 8 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_467] + PartitionCols:_col0 + Select Operator [SEL_459] (rows=130 width=4) + Output:["_col0"] + Filter Operator [FIL_453] (rows=130 width=12) + predicate:((d_qoy = 2) and (d_year = 2000) and d_date_sk is not null) + Please refer to the previous TableScan [TS_3] + <-Map 34 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_514] + PartitionCols:_col0 + Select Operator [SEL_513] (rows=143931246 width=119) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_512] (rows=143931246 width=119) + predicate:((ws_sold_date_sk BETWEEN DynamicValue(RS_50_date_dim_d_date_sk_min) AND DynamicValue(RS_50_date_dim_d_date_sk_max) and in_bloom_filter(ws_sold_date_sk, DynamicValue(RS_50_date_dim_d_date_sk_bloom_filter))) and ws_bill_addr_sk is not null and ws_sold_date_sk is not null) + TableScan [TS_40] (rows=144002668 width=119) + default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_addr_sk","ws_ext_sales_price"] + <-Reducer 17 [BROADCAST_EDGE] vectorized + BROADCAST [RS_511] + Group By Operator [GBY_510] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_483] + Group By Operator [GBY_477] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_468] (rows=130 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_459] <-Reducer 5 [ONE_TO_ONE_EDGE] FORWARD [RS_130] PartitionCols:_col0 - Merge Join Operator [MERGEJOIN_446] (rows=1605 width=322) - Conds:RS_501._col0=RS_508._col0(Inner),Output:["_col0","_col1","_col3"] + Merge Join Operator [MERGEJOIN_446] (rows=440 width=326) + Conds:RS_502._col0=RS_509._col0(Inner),Output:["_col0","_col1","_col2","_col4"] <-Reducer 12 [ONE_TO_ONE_EDGE] vectorized - FORWARD [RS_508] + FORWARD [RS_509] PartitionCols:_col0 - Group By Operator [GBY_507] (rows=1605 width=210) + Group By Operator [GBY_508] (rows=440 width=210) Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 <-Reducer 11 [SIMPLE_EDGE] SHUFFLE [RS_37] PartitionCols:_col0 - Group By Operator [GBY_36] (rows=33705 width=210) - Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_437] (rows=37399561 width=139) - Conds:RS_32._col1=RS_495._col0(Inner),Output:["_col2","_col7"] + Group By Operator [GBY_36] (rows=3960 width=210) + Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col5 + Merge Join Operator [MERGEJOIN_437] (rows=10246882 width=209) + Conds:RS_32._col1=RS_495._col0(Inner),Output:["_col2","_col5"] <-Map 32 [SIMPLE_EDGE] vectorized SHUFFLE [RS_495] PartitionCols:_col0 @@ -402,28 +404,28 @@ Stage-0 <-Reducer 10 [SIMPLE_EDGE] SHUFFLE [RS_32] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_436] (rows=37399561 width=42) - Conds:RS_506._col0=RS_465._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_436] (rows=10246882 width=115) + Conds:RS_507._col0=RS_465._col0(Inner),Output:["_col1","_col2"] <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_465] PartitionCols:_col0 - Select Operator [SEL_458] (rows=130 width=12) + Select Operator [SEL_458] (rows=130 width=4) Output:["_col0"] Filter Operator [FIL_452] (rows=130 width=12) - predicate:((d_qoy = 1) and (d_year = 2000) and d_date_sk is not null) + predicate:((d_qoy = 3) and (d_year = 2000) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] <-Map 33 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_506] + SHUFFLE [RS_507] PartitionCols:_col0 - Select Operator [SEL_505] (rows=525327191 width=114) + Select Operator [SEL_506] (rows=143931246 width=119) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_504] (rows=525327191 width=114) - 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_addr_sk is not null and ss_sold_date_sk is not null) - TableScan [TS_20] (rows=575995635 width=114) - default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_addr_sk","ss_ext_sales_price"] + Filter Operator [FIL_505] (rows=143931246 width=119) + predicate:((ws_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(ws_sold_date_sk, DynamicValue(RS_30_date_dim_d_date_sk_bloom_filter))) and ws_bill_addr_sk is not null and ws_sold_date_sk is not null) + TableScan [TS_20] (rows=144002668 width=119) + default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_addr_sk","ws_ext_sales_price"] <-Reducer 13 [BROADCAST_EDGE] vectorized - BROADCAST [RS_503] - Group By Operator [GBY_502] (rows=1 width=12) + BROADCAST [RS_504] + Group By Operator [GBY_503] (rows=1 width=12) Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_482] @@ -433,52 +435,54 @@ Stage-0 Output:["_col0"] Please refer to the previous Select Operator [SEL_458] <-Reducer 4 [ONE_TO_ONE_EDGE] vectorized - FORWARD [RS_501] + FORWARD [RS_502] PartitionCols:_col0 - Group By Operator [GBY_500] (rows=1605 width=210) - Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 - <-Reducer 3 [SIMPLE_EDGE] - SHUFFLE [RS_17] - PartitionCols:_col0 - Group By Operator [GBY_16] (rows=33705 width=210) - Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_435] (rows=37399561 width=139) - Conds:RS_12._col1=RS_494._col0(Inner),Output:["_col2","_col7"] - <-Map 32 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_494] - PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_493] - <-Reducer 2 [SIMPLE_EDGE] - SHUFFLE [RS_12] - PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_434] (rows=37399561 width=42) - Conds:RS_491._col0=RS_463._col0(Inner),Output:["_col1","_col2"] - <-Map 8 [SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_463] - PartitionCols:_col0 - Select Operator [SEL_457] (rows=130 width=12) - Output:["_col0"] - Filter Operator [FIL_451] (rows=130 width=12) - predicate:((d_qoy = 2) and (d_year = 2000) and d_date_sk is not null) - Please refer to the previous TableScan [TS_3] - <-Map 1 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_491] - PartitionCols:_col0 - Select Operator [SEL_490] (rows=525327191 width=114) - Output:["_col0","_col1","_col2"] - Filter Operator [FIL_489] (rows=525327191 width=114) - predicate:((ss_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(ss_sold_date_sk, DynamicValue(RS_10_date_dim_d_date_sk_bloom_filter))) and ss_addr_sk is not null and ss_sold_date_sk is not null) - TableScan [TS_0] (rows=575995635 width=114) - default@store_sales,store_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ss_sold_date_sk","ss_addr_sk","ss_ext_sales_price"] - <-Reducer 9 [BROADCAST_EDGE] vectorized - BROADCAST [RS_488] - Group By Operator [GBY_487] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] - <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_481] - Group By Operator [GBY_475] (rows=1 width=12) - Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] - Select Operator [SEL_464] (rows=130 width=4) - Output:["_col0"] - Please refer to the previous Select Operator [SEL_457] + Select Operator [SEL_501] (rows=440 width=214) + Output:["_col0","_col1","_col2"] + Group By Operator [GBY_500] (rows=440 width=210) + Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 + <-Reducer 3 [SIMPLE_EDGE] + SHUFFLE [RS_17] + PartitionCols:_col0 + Group By Operator [GBY_16] (rows=3960 width=210) + Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col5 + Merge Join Operator [MERGEJOIN_435] (rows=10246882 width=209) + Conds:RS_12._col1=RS_494._col0(Inner),Output:["_col2","_col5"] + <-Map 32 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_494] + PartitionCols:_col0 + Please refer to the previous Select Operator [SEL_493] + <-Reducer 2 [SIMPLE_EDGE] + SHUFFLE [RS_12] + PartitionCols:_col1 + Merge Join Operator [MERGEJOIN_434] (rows=10246882 width=115) + Conds:RS_491._col0=RS_463._col0(Inner),Output:["_col1","_col2"] + <-Map 8 [SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_463] + PartitionCols:_col0 + Select Operator [SEL_457] (rows=130 width=4) + Output:["_col0"] + Filter Operator [FIL_451] (rows=130 width=12) + predicate:((d_qoy = 1) and (d_year = 2000) and d_date_sk is not null) + Please refer to the previous TableScan [TS_3] + <-Map 1 [SIMPLE_EDGE] vectorized + SHUFFLE [RS_491] + PartitionCols:_col0 + Select Operator [SEL_490] (rows=143931246 width=119) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_489] (rows=143931246 width=119) + 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_addr_sk is not null and ws_sold_date_sk is not null) + TableScan [TS_0] (rows=144002668 width=119) + default@web_sales,web_sales,Tbl:COMPLETE,Col:COMPLETE,Output:["ws_sold_date_sk","ws_bill_addr_sk","ws_ext_sales_price"] + <-Reducer 9 [BROADCAST_EDGE] vectorized + BROADCAST [RS_488] + Group By Operator [GBY_487] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=1000000)"] + <-Map 8 [CUSTOM_SIMPLE_EDGE] vectorized + PARTITION_ONLY_SHUFFLE [RS_481] + Group By Operator [GBY_475] (rows=1 width=12) + Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] + Select Operator [SEL_464] (rows=130 width=4) + Output:["_col0"] + Please refer to the previous Select Operator [SEL_457] http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query32.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query32.q.out b/ql/src/test/results/clientpositive/perf/tez/query32.q.out index 1c1a2e7..2e52e0a 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query32.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query32.q.out @@ -93,9 +93,9 @@ Stage-0 Select Operator [SEL_34] (rows=2478 width=112) Output:["_col2"] Filter Operator [FIL_33] (rows=2478 width=112) - predicate:(_col2 > CAST( (1.3 * _col6) AS decimal(14,7))) + predicate:(_col2 > _col5) Merge Join Operator [MERGEJOIN_104] (rows=7434 width=112) - Conds:RS_30._col1=RS_31._col2(Inner),Output:["_col2","_col6"] + Conds:RS_30._col1=RS_31._col2(Inner),Output:["_col2","_col5"] <-Reducer 2 [SIMPLE_EDGE] PARTITION_ONLY_SHUFFLE [RS_30] PartitionCols:_col1 @@ -104,7 +104,7 @@ Stage-0 <-Map 6 [SIMPLE_EDGE] vectorized SHUFFLE [RS_107] PartitionCols:_col0 - Select Operator [SEL_106] (rows=8116 width=98) + Select Operator [SEL_106] (rows=8116 width=4) Output:["_col0"] Filter Operator [FIL_105] (rows=8116 width=98) predicate:(CAST( d_date AS TIMESTAMP) BETWEEN TIMESTAMP'1998-03-18 00:00:00' AND TIMESTAMP'1998-06-16 00:00:00' and d_date_sk is not null) @@ -129,7 +129,7 @@ Stage-0 Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=1000000)"] Select Operator [SEL_120] (rows=669 width=4) Output:["_col0"] - Select Operator [SEL_118] (rows=669 width=8) + Select Operator [SEL_118] (rows=669 width=4) Output:["_col0"] Filter Operator [FIL_117] (rows=669 width=7) predicate:((i_manufact_id = 269) and i_item_sk is not null) http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query33.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query33.q.out b/ql/src/test/results/clientpositive/perf/tez/query33.q.out index a76122c..6c4798e 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query33.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query33.q.out @@ -215,9 +215,9 @@ Stage-0 SHUFFLE [RS_109] PartitionCols:_col0 Group By Operator [GBY_108] (rows=19 width=115) - Output:["_col0","_col1"],aggregations:["sum(_col8)"],keys:_col1 + Output:["_col0","_col1"],aggregations:["sum(_col7)"],keys:_col1 Merge Join Operator [MERGEJOIN_304] (rows=11364 width=3) - Conds:RS_104._col0=RS_105._col3(Inner),Output:["_col1","_col8"] + Conds:RS_104._col0=RS_105._col2(Inner),Output:["_col1","_col7"] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_104] PartitionCols:_col0 @@ -250,15 +250,15 @@ Stage-0 default@item,item,Tbl:COMPLETE,Col:COMPLETE,Output:["i_category","i_manufact_id"] <-Reducer 23 [SIMPLE_EDGE] SHUFFLE [RS_105] - PartitionCols:_col3 + PartitionCols:_col2 Select Operator [SEL_100] (rows=788222 width=110) - Output:["_col3","_col5"] + Output:["_col2","_col4"] Merge Join Operator [MERGEJOIN_301] (rows=788222 width=110) Conds:RS_97._col2=RS_348._col0(Inner),Output:["_col1","_col3"] <-Map 25 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_348] PartitionCols:_col0 - Select Operator [SEL_343] (rows=8000000 width=116) + Select Operator [SEL_343] (rows=8000000 width=4) Output:["_col0"] Filter Operator [FIL_342] (rows=8000000 width=112) predicate:((ca_gmt_offset = -6) and ca_address_sk is not null) @@ -272,7 +272,7 @@ Stage-0 <-Map 17 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_332] PartitionCols:_col0 - Select Operator [SEL_327] (rows=50 width=12) + Select Operator [SEL_327] (rows=50 width=4) Output:["_col0"] Filter Operator [FIL_326] (rows=50 width=12) predicate:((d_moy = 3) and (d_year = 1999) and d_date_sk is not null) @@ -320,18 +320,18 @@ Stage-0 SHUFFLE [RS_34] PartitionCols:_col0 Group By Operator [GBY_33] (rows=64 width=115) - Output:["_col0","_col1"],aggregations:["sum(_col8)"],keys:_col1 + Output:["_col0","_col1"],aggregations:["sum(_col7)"],keys:_col1 Merge Join Operator [MERGEJOIN_302] (rows=41476 width=3) - Conds:RS_29._col0=RS_30._col3(Inner),Output:["_col1","_col8"] + Conds:RS_29._col0=RS_30._col2(Inner),Output:["_col1","_col7"] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_29] PartitionCols:_col0 Please refer to the previous Merge Join Operator [MERGEJOIN_293] <-Reducer 16 [SIMPLE_EDGE] SHUFFLE [RS_30] - PartitionCols:_col3 + PartitionCols:_col2 Select Operator [SEL_25] (rows=2876890 width=4) - Output:["_col3","_col5"] + Output:["_col2","_col4"] Merge Join Operator [MERGEJOIN_295] (rows=2876890 width=4) Conds:RS_22._col2=RS_344._col0(Inner),Output:["_col1","_col3"] <-Map 25 [SIMPLE_EDGE] vectorized @@ -389,18 +389,18 @@ Stage-0 SHUFFLE [RS_71] PartitionCols:_col0 Group By Operator [GBY_70] (rows=35 width=115) - Output:["_col0","_col1"],aggregations:["sum(_col8)"],keys:_col1 + Output:["_col0","_col1"],aggregations:["sum(_col7)"],keys:_col1 Merge Join Operator [MERGEJOIN_303] (rows=22352 width=3) - Conds:RS_66._col0=RS_67._col4(Inner),Output:["_col1","_col8"] + Conds:RS_66._col0=RS_67._col3(Inner),Output:["_col1","_col7"] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_66] PartitionCols:_col0 Please refer to the previous Merge Join Operator [MERGEJOIN_293] <-Reducer 20 [SIMPLE_EDGE] SHUFFLE [RS_67] - PartitionCols:_col4 + PartitionCols:_col3 Select Operator [SEL_62] (rows=1550375 width=13) - Output:["_col4","_col5"] + Output:["_col3","_col4"] Merge Join Operator [MERGEJOIN_298] (rows=1550375 width=13) Conds:RS_59._col1=RS_346._col0(Inner),Output:["_col2","_col3"] <-Map 25 [SIMPLE_EDGE] vectorized http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query34.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query34.q.out b/ql/src/test/results/clientpositive/perf/tez/query34.q.out index b40a921..fd60a3a 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query34.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query34.q.out @@ -126,7 +126,7 @@ Stage-0 <-Map 13 [SIMPLE_EDGE] vectorized SHUFFLE [RS_122] PartitionCols:_col0 - Select Operator [SEL_121] (rows=112 width=102) + Select Operator [SEL_121] (rows=112 width=4) Output:["_col0"] Filter Operator [FIL_120] (rows=112 width=102) predicate:((s_county) IN ('Mobile County', 'Maverick County', 'Huron County', 'Kittitas County', 'Fairfield County', 'Jackson County', 'Barrow County', 'Pennington County') and s_store_sk is not null) @@ -140,7 +140,7 @@ Stage-0 <-Map 11 [SIMPLE_EDGE] vectorized SHUFFLE [RS_114] PartitionCols:_col0 - Select Operator [SEL_113] (rows=480 width=104) + Select Operator [SEL_113] (rows=480 width=4) Output:["_col0"] Filter Operator [FIL_112] (rows=480 width=104) predicate:((hd_buy_potential) IN ('>10000', 'unknown') and (hd_vehicle_count > 0) and CASE WHEN ((hd_vehicle_count > 0)) THEN (((UDFToDouble(hd_dep_count) / UDFToDouble(hd_vehicle_count)) > 1.2D)) ELSE (null) END and hd_demo_sk is not null) @@ -154,7 +154,7 @@ Stage-0 <-Map 9 [SIMPLE_EDGE] vectorized SHUFFLE [RS_106] PartitionCols:_col0 - Select Operator [SEL_105] (rows=595 width=12) + Select Operator [SEL_105] (rows=595 width=4) Output:["_col0"] Filter Operator [FIL_104] (rows=595 width=12) predicate:((d_dom BETWEEN 1 AND 3 or d_dom BETWEEN 25 AND 28) and (d_year) IN (2000, 2001, 2002) 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/query35.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query35.q.out b/ql/src/test/results/clientpositive/perf/tez/query35.q.out index 4499383..f9e67b6 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query35.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query35.q.out @@ -201,7 +201,7 @@ Stage-0 <-Map 15 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_194] PartitionCols:_col0 - Select Operator [SEL_193] (rows=217 width=12) + Select Operator [SEL_193] (rows=217 width=4) Output:["_col0"] Filter Operator [FIL_192] (rows=217 width=12) predicate:((d_qoy < 4) and (d_year = 1999) 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/query36.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query36.q.out b/ql/src/test/results/clientpositive/perf/tez/query36.q.out index 4f4ce8a..a367f2e 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query36.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query36.q.out @@ -112,7 +112,7 @@ Stage-0 Select Operator [SEL_21] (rows=30601888 width=232) Output:["_col0","_col1","_col2","_col3"] Merge Join Operator [MERGEJOIN_82] (rows=30601888 width=232) - Conds:RS_18._col1=RS_104._col0(Inner),Output:["_col3","_col4","_col10","_col11"] + Conds:RS_18._col1=RS_104._col0(Inner),Output:["_col3","_col4","_col8","_col9"] <-Map 12 [SIMPLE_EDGE] vectorized SHUFFLE [RS_104] PartitionCols:_col0 @@ -130,7 +130,7 @@ Stage-0 <-Map 10 [SIMPLE_EDGE] vectorized SHUFFLE [RS_93] PartitionCols:_col0 - Select Operator [SEL_92] (rows=278 width=90) + Select Operator [SEL_92] (rows=278 width=4) Output:["_col0"] Filter Operator [FIL_91] (rows=278 width=90) predicate:((s_state) IN ('SD', 'FL', 'MI', 'LA', 'MO', 'SC', 'AL', 'GA') and s_store_sk is not null) @@ -144,7 +144,7 @@ Stage-0 <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_85] PartitionCols:_col0 - Select Operator [SEL_84] (rows=652 width=8) + Select Operator [SEL_84] (rows=652 width=4) Output:["_col0"] Filter Operator [FIL_83] (rows=652 width=8) predicate:((d_year = 1999) 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/query37.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query37.q.out b/ql/src/test/results/clientpositive/perf/tez/query37.q.out index 4407a48..c7c29fb 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query37.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query37.q.out @@ -83,7 +83,7 @@ Stage-0 <-Map 11 [SIMPLE_EDGE] vectorized SHUFFLE [RS_93] PartitionCols:_col0 - Select Operator [SEL_92] (rows=8116 width=98) + Select Operator [SEL_92] (rows=8116 width=4) Output:["_col0"] Filter Operator [FIL_91] (rows=8116 width=98) predicate:(CAST( d_date AS TIMESTAMP) BETWEEN TIMESTAMP'2001-06-02 00:00:00' AND TIMESTAMP'2001-08-01 00:00:00' and d_date_sk is not null) @@ -92,7 +92,7 @@ Stage-0 <-Map 8 [SIMPLE_EDGE] vectorized SHUFFLE [RS_90] PartitionCols:_col0 - Select Operator [SEL_89] (rows=4176000 width=11) + Select Operator [SEL_89] (rows=4176000 width=8) Output:["_col0","_col1"] Filter Operator [FIL_88] (rows=4176000 width=11) predicate:(inv_date_sk is not null and inv_item_sk is not null and inv_quantity_on_hand BETWEEN 100 AND 500) @@ -106,7 +106,7 @@ Stage-0 <-Map 6 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_82] PartitionCols:_col0 - Select Operator [SEL_81] (rows=297 width=404) + Select Operator [SEL_81] (rows=297 width=400) Output:["_col0","_col1","_col2","_col3"] Filter Operator [FIL_80] (rows=297 width=404) predicate:((i_manufact_id) IN (678, 964, 918, 849) and i_current_price BETWEEN 22 AND 52 and i_item_sk is not null) http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query38.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query38.q.out b/ql/src/test/results/clientpositive/perf/tez/query38.q.out index e91141d..ddf6e6e 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query38.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query38.q.out @@ -112,9 +112,9 @@ Stage-0 SHUFFLE [RS_42] PartitionCols:_col0, _col1, _col2 Group By Operator [GBY_41] (rows=49146883 width=274) - Output:["_col0","_col1","_col2"],keys:_col7, _col6, _col3 + Output:["_col0","_col1","_col2"],keys:_col6, _col5, _col3 Merge Join Operator [MERGEJOIN_178] (rows=49146883 width=274) - Conds:RS_37._col1=RS_221._col0(Inner),Output:["_col3","_col6","_col7"] + Conds:RS_37._col1=RS_221._col0(Inner),Output:["_col3","_col5","_col6"] <-Map 18 [SIMPLE_EDGE] vectorized SHUFFLE [RS_221] PartitionCols:_col0 @@ -132,7 +132,7 @@ Stage-0 <-Map 8 [SIMPLE_EDGE] vectorized PARTITION_ONLY_SHUFFLE [RS_203] PartitionCols:_col0 - Select Operator [SEL_200] (rows=317 width=102) + Select Operator [SEL_200] (rows=317 width=98) Output:["_col0","_col1"] Filter Operator [FIL_199] (rows=317 width=102) predicate:(d_date_sk is not null and d_month_seq BETWEEN 1212 AND 1223) @@ -173,9 +173,9 @@ Stage-0 SHUFFLE [RS_68] PartitionCols:_col0, _col1, _col2 Group By Operator [GBY_67] (rows=24986582 width=274) - Output:["_col0","_col1","_col2"],keys:_col7, _col6, _col3 + Output:["_col0","_col1","_col2"],keys:_col6, _col5, _col3 Merge Join Operator [MERGEJOIN_180] (rows=24986582 width=274) - Conds:RS_63._col1=RS_222._col0(Inner),Output:["_col3","_col6","_col7"] + Conds:RS_63._col1=RS_222._col0(Inner),Output:["_col3","_col5","_col6"] <-Map 18 [SIMPLE_EDGE] vectorized SHUFFLE [RS_222] PartitionCols:_col0 @@ -224,9 +224,9 @@ Stage-0 SHUFFLE [RS_17] PartitionCols:_col0, _col1, _col2 Group By Operator [GBY_16] (rows=91197425 width=274) - Output:["_col0","_col1","_col2"],keys:_col7, _col6, _col3 + Output:["_col0","_col1","_col2"],keys:_col6, _col5, _col3 Merge Join Operator [MERGEJOIN_176] (rows=91197425 width=274) - Conds:RS_12._col1=RS_220._col0(Inner),Output:["_col3","_col6","_col7"] + Conds:RS_12._col1=RS_220._col0(Inner),Output:["_col3","_col5","_col6"] <-Map 18 [SIMPLE_EDGE] vectorized SHUFFLE [RS_220] PartitionCols:_col0 http://git-wip-us.apache.org/repos/asf/hive/blob/55887646/ql/src/test/results/clientpositive/perf/tez/query39.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query39.q.out b/ql/src/test/results/clientpositive/perf/tez/query39.q.out index 103e921..691e301 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query39.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query39.q.out @@ -105,7 +105,7 @@ Stage-0 Select Operator [SEL_49] (rows=1032514 width=108) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] Merge Join Operator [MERGEJOIN_201] (rows=1032514 width=108) - Conds:RS_46._col2=RS_220._col0(Inner),Output:["_col3","_col7","_col8","_col9"] + Conds:RS_46._col2=RS_220._col0(Inner),Output:["_col3","_col5","_col6","_col7"] <-Map 14 [SIMPLE_EDGE] vectorized SHUFFLE [RS_220] PartitionCols:_col0 @@ -119,7 +119,7 @@ Stage-0 SHUFFLE [RS_46] PartitionCols:_col2 Merge Join Operator [MERGEJOIN_200] (rows=1032514 width=8) - Conds:RS_43._col1=RS_216._col0(Inner),Output:["_col2","_col3","_col7"] + Conds:RS_43._col1=RS_216._col0(Inner),Output:["_col2","_col3","_col5"] <-Map 13 [SIMPLE_EDGE] vectorized SHUFFLE [RS_216] PartitionCols:_col0 @@ -146,7 +146,7 @@ Stage-0 <-Map 12 [SIMPLE_EDGE] vectorized SHUFFLE [RS_212] PartitionCols:_col0 - Select Operator [SEL_210] (rows=50 width=12) + Select Operator [SEL_210] (rows=50 width=4) Output:["_col0"] Filter Operator [FIL_208] (rows=50 width=12) predicate:((d_moy = 5) and (d_year = 1999) and d_date_sk is not null) @@ -171,7 +171,7 @@ Stage-0 Select Operator [SEL_21] (rows=1032514 width=108) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] Merge Join Operator [MERGEJOIN_198] (rows=1032514 width=108) - Conds:RS_18._col2=RS_219._col0(Inner),Output:["_col3","_col7","_col8","_col9"] + Conds:RS_18._col2=RS_219._col0(Inner),Output:["_col3","_col5","_col6","_col7"] <-Map 14 [SIMPLE_EDGE] vectorized SHUFFLE [RS_219] PartitionCols:_col0 @@ -180,7 +180,7 @@ Stage-0 SHUFFLE [RS_18] PartitionCols:_col2 Merge Join Operator [MERGEJOIN_197] (rows=1032514 width=8) - Conds:RS_15._col1=RS_215._col0(Inner),Output:["_col2","_col3","_col7"] + Conds:RS_15._col1=RS_215._col0(Inner),Output:["_col2","_col3","_col5"] <-Map 13 [SIMPLE_EDGE] vectorized SHUFFLE [RS_215] PartitionCols:_col0 @@ -197,7 +197,7 @@ Stage-0 <-Map 12 [SIMPLE_EDGE] vectorized SHUFFLE [RS_211] PartitionCols:_col0 - Select Operator [SEL_209] (rows=50 width=12) + Select Operator [SEL_209] (rows=50 width=4) Output:["_col0"] Filter Operator [FIL_207] (rows=50 width=12) predicate:((d_moy = 4) and (d_year = 1999) and d_date_sk is not null)
