http://git-wip-us.apache.org/repos/asf/hive/blob/a74c1e7c/ql/src/test/results/clientpositive/perf/query31.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/query31.q.out b/ql/src/test/results/clientpositive/perf/query31.q.out index 9e3dad4..b456244 100644 --- a/ql/src/test/results/clientpositive/perf/query31.q.out +++ b/ql/src/test/results/clientpositive/perf/query31.q.out @@ -32,16 +32,16 @@ Stage-0 limit:-1 Stage-1 Reducer 6 - File Output Operator [FS_135] + File Output Operator [FS_136] Select Operator [SEL_134] (rows=287493839 width=88) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] <-Reducer 5 [SIMPLE_EDGE] SHUFFLE [RS_133] Select Operator [SEL_132] (rows=287493839 width=88) - Output:["_col0","_col2","_col3","_col4","_col5"] + Output:["_col0","_col1","_col2","_col3","_col4"] Filter Operator [FIL_130] (rows=287493839 width=88) 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_269] (rows=1149975359 width=88) + Merge Join Operator [MERGEJOIN_270] (rows=1149975359 width=88) Conds:RS_125._col0=RS_126._col0(Inner),RS_125._col0=RS_127._col0(Inner),RS_125._col0=RS_128._col0(Inner),Output:["_col0","_col1","_col3","_col5","_col7","_col9","_col11"] <-Reducer 12 [SIMPLE_EDGE] SHUFFLE [RS_127] @@ -53,28 +53,28 @@ Stage-0 PartitionCols:_col0 Group By Operator [GBY_56] (rows=696954748 width=88) Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_261] (rows=696954748 width=88) + Merge Join Operator [MERGEJOIN_262] (rows=696954748 width=88) Conds:RS_52._col1=RS_53._col0(Inner),Output:["_col2","_col7"] <-Map 24 [SIMPLE_EDGE] SHUFFLE [RS_53] PartitionCols:_col0 Select Operator [SEL_48] (rows=40000000 width=1014) Output:["_col0","_col1"] - Filter Operator [FIL_246] (rows=40000000 width=1014) + Filter Operator [FIL_247] (rows=40000000 width=1014) predicate:(ca_address_sk is not null and ca_county is not null) TableScan [TS_6] (rows=40000000 width=1014) default@customer_address,customer_address,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_county"] <-Reducer 10 [SIMPLE_EDGE] SHUFFLE [RS_52] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_260] (rows=633595212 width=88) + Merge Join Operator [MERGEJOIN_261] (rows=633595212 width=88) Conds:RS_49._col0=RS_50._col0(Inner),Output:["_col1","_col2"] <-Map 13 [SIMPLE_EDGE] SHUFFLE [RS_50] PartitionCols:_col0 Select Operator [SEL_45] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_245] (rows=18262 width=1119) + Filter Operator [FIL_246] (rows=18262 width=1119) predicate:((d_qoy = 3) and (d_year = 1998) and d_date_sk is not null) TableScan [TS_3] (rows=73049 width=1119) default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_qoy"] @@ -83,14 +83,14 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_42] (rows=575995635 width=88) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_244] (rows=575995635 width=88) + Filter Operator [FIL_245] (rows=575995635 width=88) predicate:(ss_sold_date_sk is not null and ss_addr_sk is not null) TableScan [TS_0] (rows=575995635 width=88) default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_addr_sk","ss_ext_sales_price"] <-Reducer 17 [SIMPLE_EDGE] SHUFFLE [RS_128] PartitionCols:_col0 - Merge Join Operator [MERGEJOIN_268] (rows=191667561 width=135) + Merge Join Operator [MERGEJOIN_269] (rows=191667561 width=135) Conds:RS_120._col0=RS_121._col0(Inner),RS_120._col0=RS_122._col0(Inner),Output:["_col0","_col1","_col3","_col5"] <-Reducer 16 [SIMPLE_EDGE] SHUFFLE [RS_120] @@ -102,27 +102,27 @@ Stage-0 PartitionCols:_col0 Group By Operator [GBY_76] (rows=174243235 width=135) Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_263] (rows=174243235 width=135) + Merge Join Operator [MERGEJOIN_264] (rows=174243235 width=135) Conds:RS_72._col1=RS_73._col0(Inner),Output:["_col2","_col7"] <-Map 24 [SIMPLE_EDGE] SHUFFLE [RS_73] PartitionCols:_col0 Select Operator [SEL_68] (rows=40000000 width=1014) Output:["_col0","_col1"] - Filter Operator [FIL_249] (rows=40000000 width=1014) + Filter Operator [FIL_250] (rows=40000000 width=1014) predicate:(ca_address_sk is not null and ca_county is not null) Please refer to the previous TableScan [TS_6] <-Reducer 14 [SIMPLE_EDGE] SHUFFLE [RS_72] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_262] (rows=158402938 width=135) + Merge Join Operator [MERGEJOIN_263] (rows=158402938 width=135) Conds:RS_69._col0=RS_70._col0(Inner),Output:["_col1","_col2"] <-Map 13 [SIMPLE_EDGE] SHUFFLE [RS_70] PartitionCols:_col0 Select Operator [SEL_65] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_248] (rows=18262 width=1119) + Filter Operator [FIL_249] (rows=18262 width=1119) predicate:((d_qoy = 1) and (d_year = 1998) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] <-Map 25 [SIMPLE_EDGE] @@ -130,7 +130,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_62] (rows=144002668 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_247] (rows=144002668 width=135) + Filter Operator [FIL_248] (rows=144002668 width=135) predicate:(ws_sold_date_sk is not null and ws_bill_addr_sk is not null) TableScan [TS_60] (rows=144002668 width=135) default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_bill_addr_sk","ws_ext_sales_price"] @@ -144,27 +144,27 @@ Stage-0 PartitionCols:_col0 Group By Operator [GBY_96] (rows=174243235 width=135) Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_265] (rows=174243235 width=135) + Merge Join Operator [MERGEJOIN_266] (rows=174243235 width=135) Conds:RS_92._col1=RS_93._col0(Inner),Output:["_col2","_col7"] <-Map 24 [SIMPLE_EDGE] SHUFFLE [RS_93] PartitionCols:_col0 Select Operator [SEL_88] (rows=40000000 width=1014) Output:["_col0","_col1"] - Filter Operator [FIL_252] (rows=40000000 width=1014) + Filter Operator [FIL_253] (rows=40000000 width=1014) predicate:(ca_address_sk is not null and ca_county is not null) Please refer to the previous TableScan [TS_6] <-Reducer 18 [SIMPLE_EDGE] SHUFFLE [RS_92] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_264] (rows=158402938 width=135) + Merge Join Operator [MERGEJOIN_265] (rows=158402938 width=135) Conds:RS_89._col0=RS_90._col0(Inner),Output:["_col1","_col2"] <-Map 13 [SIMPLE_EDGE] SHUFFLE [RS_90] PartitionCols:_col0 Select Operator [SEL_85] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_251] (rows=18262 width=1119) + Filter Operator [FIL_252] (rows=18262 width=1119) predicate:((d_qoy = 2) and (d_year = 1998) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] <-Map 25 [SIMPLE_EDGE] @@ -172,7 +172,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_82] (rows=144002668 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_250] (rows=144002668 width=135) + Filter Operator [FIL_251] (rows=144002668 width=135) predicate:(ws_sold_date_sk is not null and ws_bill_addr_sk is not null) Please refer to the previous TableScan [TS_60] <-Reducer 23 [SIMPLE_EDGE] @@ -185,27 +185,27 @@ Stage-0 PartitionCols:_col0 Group By Operator [GBY_116] (rows=174243235 width=135) Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_267] (rows=174243235 width=135) + Merge Join Operator [MERGEJOIN_268] (rows=174243235 width=135) Conds:RS_112._col1=RS_113._col0(Inner),Output:["_col2","_col7"] <-Map 24 [SIMPLE_EDGE] SHUFFLE [RS_113] PartitionCols:_col0 Select Operator [SEL_108] (rows=40000000 width=1014) Output:["_col0","_col1"] - Filter Operator [FIL_255] (rows=40000000 width=1014) + Filter Operator [FIL_256] (rows=40000000 width=1014) predicate:(ca_address_sk is not null and ca_county is not null) Please refer to the previous TableScan [TS_6] <-Reducer 21 [SIMPLE_EDGE] SHUFFLE [RS_112] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_266] (rows=158402938 width=135) + Merge Join Operator [MERGEJOIN_267] (rows=158402938 width=135) Conds:RS_109._col0=RS_110._col0(Inner),Output:["_col1","_col2"] <-Map 13 [SIMPLE_EDGE] SHUFFLE [RS_110] PartitionCols:_col0 Select Operator [SEL_105] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_254] (rows=18262 width=1119) + Filter Operator [FIL_255] (rows=18262 width=1119) predicate:((d_qoy = 3) and (d_year = 1998) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] <-Map 25 [SIMPLE_EDGE] @@ -213,7 +213,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_102] (rows=144002668 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_253] (rows=144002668 width=135) + Filter Operator [FIL_254] (rows=144002668 width=135) predicate:(ws_sold_date_sk is not null and ws_bill_addr_sk is not null) Please refer to the previous TableScan [TS_60] <-Reducer 4 [SIMPLE_EDGE] @@ -226,27 +226,27 @@ Stage-0 PartitionCols:_col0 Group By Operator [GBY_16] (rows=696954748 width=88) Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_257] (rows=696954748 width=88) + Merge Join Operator [MERGEJOIN_258] (rows=696954748 width=88) Conds:RS_12._col1=RS_13._col0(Inner),Output:["_col2","_col7"] <-Map 24 [SIMPLE_EDGE] SHUFFLE [RS_13] PartitionCols:_col0 Select Operator [SEL_8] (rows=40000000 width=1014) Output:["_col0","_col1"] - Filter Operator [FIL_240] (rows=40000000 width=1014) + Filter Operator [FIL_241] (rows=40000000 width=1014) predicate:(ca_address_sk is not null and ca_county is not null) Please refer to the previous TableScan [TS_6] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_12] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_256] (rows=633595212 width=88) + Merge Join Operator [MERGEJOIN_257] (rows=633595212 width=88) Conds:RS_9._col0=RS_10._col0(Inner),Output:["_col1","_col2"] <-Map 13 [SIMPLE_EDGE] SHUFFLE [RS_10] PartitionCols:_col0 Select Operator [SEL_5] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_239] (rows=18262 width=1119) + Filter Operator [FIL_240] (rows=18262 width=1119) predicate:((d_qoy = 2) and (d_year = 1998) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] <-Map 1 [SIMPLE_EDGE] @@ -254,7 +254,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_2] (rows=575995635 width=88) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_238] (rows=575995635 width=88) + Filter Operator [FIL_239] (rows=575995635 width=88) predicate:(ss_sold_date_sk is not null and ss_addr_sk is not null) Please refer to the previous TableScan [TS_0] <-Reducer 9 [SIMPLE_EDGE] @@ -267,27 +267,27 @@ Stage-0 PartitionCols:_col0 Group By Operator [GBY_36] (rows=696954748 width=88) Output:["_col0","_col1"],aggregations:["sum(_col2)"],keys:_col7 - Merge Join Operator [MERGEJOIN_259] (rows=696954748 width=88) + Merge Join Operator [MERGEJOIN_260] (rows=696954748 width=88) Conds:RS_32._col1=RS_33._col0(Inner),Output:["_col2","_col7"] <-Map 24 [SIMPLE_EDGE] SHUFFLE [RS_33] PartitionCols:_col0 Select Operator [SEL_28] (rows=40000000 width=1014) Output:["_col0","_col1"] - Filter Operator [FIL_243] (rows=40000000 width=1014) + Filter Operator [FIL_244] (rows=40000000 width=1014) predicate:(ca_address_sk is not null and ca_county is not null) Please refer to the previous TableScan [TS_6] <-Reducer 7 [SIMPLE_EDGE] SHUFFLE [RS_32] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_258] (rows=633595212 width=88) + Merge Join Operator [MERGEJOIN_259] (rows=633595212 width=88) Conds:RS_29._col0=RS_30._col0(Inner),Output:["_col1","_col2"] <-Map 13 [SIMPLE_EDGE] SHUFFLE [RS_30] PartitionCols:_col0 Select Operator [SEL_25] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_242] (rows=18262 width=1119) + Filter Operator [FIL_243] (rows=18262 width=1119) predicate:((d_qoy = 1) and (d_year = 1998) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] <-Map 1 [SIMPLE_EDGE] @@ -295,7 +295,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_22] (rows=575995635 width=88) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_241] (rows=575995635 width=88) + Filter Operator [FIL_242] (rows=575995635 width=88) predicate:(ss_sold_date_sk is not null and ss_addr_sk is not null) Please refer to the previous TableScan [TS_0]
http://git-wip-us.apache.org/repos/asf/hive/blob/a74c1e7c/ql/src/test/results/clientpositive/perf/query36.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/query36.q.out b/ql/src/test/results/clientpositive/perf/query36.q.out index 57ab26a..b5110d9 100644 --- a/ql/src/test/results/clientpositive/perf/query36.q.out +++ b/ql/src/test/results/clientpositive/perf/query36.q.out @@ -68,10 +68,10 @@ Reducer 7 <- Reducer 6 (SIMPLE_EDGE) Stage-0 Fetch Operator - limit:100 + limit:-1 Stage-1 Reducer 7 - File Output Operator [FS_35] + File Output Operator [FS_36] Limit [LIM_34] (rows=100 width=88) Number of rows:100 Select Operator [SEL_33] (rows=1149975358 width=88) @@ -79,7 +79,7 @@ Stage-0 <-Reducer 6 [SIMPLE_EDGE] SHUFFLE [RS_32] Select Operator [SEL_30] (rows=1149975358 width=88) - Output:["_col0","_col1","_col2","_col3","_col4"] + Output:["_col0","_col1","_col2","_col3","_col4","_col5"] PTF Operator [PTF_29] (rows=1149975358 width=88) Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(_col4 / _col5) ASC NULLS FIRST","partition by:":"(grouping(_col6, 1) + grouping(_col6, 0)), CASE WHEN ((grouping(_col6, 0) = 0)) THEN (_col0) ELSE (null) END"}] Select Operator [SEL_28] (rows=1149975358 width=88) @@ -98,42 +98,42 @@ Stage-0 Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col2)","sum(_col3)"],keys:_col0, _col1, 0 Select Operator [SEL_21] (rows=766650239 width=88) Output:["_col0","_col1","_col2","_col3"] - Merge Join Operator [MERGEJOIN_51] (rows=766650239 width=88) + Merge Join Operator [MERGEJOIN_52] (rows=766650239 width=88) Conds:RS_18._col1=RS_19._col0(Inner),Output:["_col3","_col4","_col10","_col11"] <-Map 10 [SIMPLE_EDGE] SHUFFLE [RS_19] PartitionCols:_col0 Select Operator [SEL_11] (rows=462000 width=1436) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_48] (rows=462000 width=1436) + Filter Operator [FIL_49] (rows=462000 width=1436) predicate:i_item_sk is not null TableScan [TS_9] (rows=462000 width=1436) default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_class","i_category"] <-Reducer 3 [SIMPLE_EDGE] SHUFFLE [RS_18] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_50] (rows=696954748 width=88) + Merge Join Operator [MERGEJOIN_51] (rows=696954748 width=88) Conds:RS_15._col2=RS_16._col0(Inner),Output:["_col1","_col3","_col4"] <-Map 9 [SIMPLE_EDGE] SHUFFLE [RS_16] PartitionCols:_col0 Select Operator [SEL_8] (rows=852 width=1910) Output:["_col0"] - Filter Operator [FIL_47] (rows=852 width=1910) + Filter Operator [FIL_48] (rows=852 width=1910) predicate:((s_state) IN ('SD', 'FL', 'MI', 'LA', 'MO', 'SC', 'AL', 'GA') and s_store_sk is not null) TableScan [TS_6] (rows=1704 width=1910) default@store,store,Tbl:COMPLETE,Col:NONE,Output:["s_store_sk","s_state"] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_15] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_49] (rows=633595212 width=88) + Merge Join Operator [MERGEJOIN_50] (rows=633595212 width=88) Conds:RS_12._col0=RS_13._col0(Inner),Output:["_col1","_col2","_col3","_col4"] <-Map 1 [SIMPLE_EDGE] SHUFFLE [RS_12] PartitionCols:_col0 Select Operator [SEL_2] (rows=575995635 width=88) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_45] (rows=575995635 width=88) + Filter Operator [FIL_46] (rows=575995635 width=88) predicate:(ss_sold_date_sk is not null and ss_item_sk is not null and ss_store_sk is not null) TableScan [TS_0] (rows=575995635 width=88) default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_store_sk","ss_ext_sales_price","ss_net_profit"] @@ -142,7 +142,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_5] (rows=36524 width=1119) Output:["_col0"] - Filter Operator [FIL_46] (rows=36524 width=1119) + Filter Operator [FIL_47] (rows=36524 width=1119) predicate:((d_year = 1999) and d_date_sk is not null) TableScan [TS_3] (rows=73049 width=1119) default@date_dim,d1,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year"] http://git-wip-us.apache.org/repos/asf/hive/blob/a74c1e7c/ql/src/test/results/clientpositive/perf/query39.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/query39.q.out b/ql/src/test/results/clientpositive/perf/query39.q.out index dcf3cb2..3e34c27 100644 --- a/ql/src/test/results/clientpositive/perf/query39.q.out +++ b/ql/src/test/results/clientpositive/perf/query39.q.out @@ -21,14 +21,14 @@ Stage-0 limit:-1 Stage-1 Reducer 7 - File Output Operator [FS_62] + File Output Operator [FS_63] Select Operator [SEL_61] (rows=13756683 width=15) Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9"] <-Reducer 6 [SIMPLE_EDGE] SHUFFLE [RS_60] Select Operator [SEL_59] (rows=13756683 width=15) - Output:["_col0","_col1","_col3","_col4","_col5","_col6","_col8","_col9"] - Merge Join Operator [MERGEJOIN_103] (rows=13756683 width=15) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7"] + Merge Join Operator [MERGEJOIN_104] (rows=13756683 width=15) Conds:RS_56._col1, _col2=RS_57._col1, _col2(Inner),Output:["_col1","_col2","_col3","_col4","_col6","_col7","_col8","_col9"] <-Reducer 11 [SIMPLE_EDGE] SHUFFLE [RS_57] @@ -46,42 +46,42 @@ Stage-0 PartitionCols:_col0, _col1, _col2 Group By Operator [GBY_50] (rows=50024305 width=15) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["stddev_samp(_col3)","avg(_col3)"],keys:_col8, _col7, _col9 - Merge Join Operator [MERGEJOIN_102] (rows=50024305 width=15) + Merge Join Operator [MERGEJOIN_103] (rows=50024305 width=15) Conds:RS_46._col2=RS_47._col0(Inner),Output:["_col3","_col7","_col8","_col9"] <-Map 14 [SIMPLE_EDGE] SHUFFLE [RS_47] PartitionCols:_col0 Select Operator [SEL_39] (rows=27 width=1029) Output:["_col0","_col1"] - Filter Operator [FIL_96] (rows=27 width=1029) + Filter Operator [FIL_97] (rows=27 width=1029) predicate:w_warehouse_sk is not null TableScan [TS_9] (rows=27 width=1029) default@warehouse,warehouse,Tbl:COMPLETE,Col:NONE,Output:["w_warehouse_sk","w_warehouse_name"] <-Reducer 9 [SIMPLE_EDGE] SHUFFLE [RS_46] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_101] (rows=45476640 width=15) + Merge Join Operator [MERGEJOIN_102] (rows=45476640 width=15) Conds:RS_43._col1=RS_44._col0(Inner),Output:["_col2","_col3","_col7"] <-Map 13 [SIMPLE_EDGE] SHUFFLE [RS_44] PartitionCols:_col0 Select Operator [SEL_36] (rows=462000 width=1436) Output:["_col0"] - Filter Operator [FIL_95] (rows=462000 width=1436) + Filter Operator [FIL_96] (rows=462000 width=1436) predicate:i_item_sk is not null TableScan [TS_6] (rows=462000 width=1436) default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk"] <-Reducer 8 [SIMPLE_EDGE] SHUFFLE [RS_43] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_100] (rows=41342400 width=15) + Merge Join Operator [MERGEJOIN_101] (rows=41342400 width=15) Conds:RS_40._col0=RS_41._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 1 [SIMPLE_EDGE] SHUFFLE [RS_40] PartitionCols:_col0 Select Operator [SEL_30] (rows=37584000 width=15) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_93] (rows=37584000 width=15) + Filter Operator [FIL_94] (rows=37584000 width=15) predicate:(inv_item_sk is not null and inv_warehouse_sk is not null and inv_date_sk is not null) TableScan [TS_0] (rows=37584000 width=15) default@inventory,inventory,Tbl:COMPLETE,Col:NONE,Output:["inv_date_sk","inv_item_sk","inv_warehouse_sk","inv_quantity_on_hand"] @@ -90,7 +90,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_33] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_94] (rows=18262 width=1119) + Filter Operator [FIL_95] (rows=18262 width=1119) predicate:((d_year = 1999) and (d_moy = 4) and d_date_sk is not null) TableScan [TS_3] (rows=73049 width=1119) default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"] @@ -110,40 +110,40 @@ Stage-0 PartitionCols:_col0, _col1, _col2 Group By Operator [GBY_22] (rows=50024305 width=15) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["stddev_samp(_col3)","avg(_col3)"],keys:_col8, _col7, _col9 - Merge Join Operator [MERGEJOIN_99] (rows=50024305 width=15) + Merge Join Operator [MERGEJOIN_100] (rows=50024305 width=15) Conds:RS_18._col2=RS_19._col0(Inner),Output:["_col3","_col7","_col8","_col9"] <-Map 14 [SIMPLE_EDGE] SHUFFLE [RS_19] PartitionCols:_col0 Select Operator [SEL_11] (rows=27 width=1029) Output:["_col0","_col1"] - Filter Operator [FIL_92] (rows=27 width=1029) + Filter Operator [FIL_93] (rows=27 width=1029) predicate:w_warehouse_sk is not null Please refer to the previous TableScan [TS_9] <-Reducer 3 [SIMPLE_EDGE] SHUFFLE [RS_18] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_98] (rows=45476640 width=15) + Merge Join Operator [MERGEJOIN_99] (rows=45476640 width=15) Conds:RS_15._col1=RS_16._col0(Inner),Output:["_col2","_col3","_col7"] <-Map 13 [SIMPLE_EDGE] SHUFFLE [RS_16] PartitionCols:_col0 Select Operator [SEL_8] (rows=462000 width=1436) Output:["_col0"] - Filter Operator [FIL_91] (rows=462000 width=1436) + Filter Operator [FIL_92] (rows=462000 width=1436) predicate:i_item_sk is not null Please refer to the previous TableScan [TS_6] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_15] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_97] (rows=41342400 width=15) + Merge Join Operator [MERGEJOIN_98] (rows=41342400 width=15) Conds:RS_12._col0=RS_13._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 1 [SIMPLE_EDGE] SHUFFLE [RS_12] PartitionCols:_col0 Select Operator [SEL_2] (rows=37584000 width=15) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_89] (rows=37584000 width=15) + Filter Operator [FIL_90] (rows=37584000 width=15) predicate:(inv_item_sk is not null and inv_warehouse_sk is not null and inv_date_sk is not null) Please refer to the previous TableScan [TS_0] <-Map 12 [SIMPLE_EDGE] @@ -151,7 +151,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_5] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_90] (rows=18262 width=1119) + Filter Operator [FIL_91] (rows=18262 width=1119) predicate:((d_year = 1999) and (d_moy = 3) and d_date_sk is not null) Please refer to the previous TableScan [TS_3] http://git-wip-us.apache.org/repos/asf/hive/blob/a74c1e7c/ql/src/test/results/clientpositive/perf/query42.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/query42.q.out b/ql/src/test/results/clientpositive/perf/query42.q.out index 3bebac3..307ef98 100644 --- a/ql/src/test/results/clientpositive/perf/query42.q.out +++ b/ql/src/test/results/clientpositive/perf/query42.q.out @@ -12,18 +12,18 @@ Reducer 5 <- Reducer 4 (SIMPLE_EDGE) Stage-0 Fetch Operator - limit:100 + limit:-1 Stage-1 Reducer 5 - File Output Operator [FS_23] - Limit [LIM_22] (rows=100 width=88) - Number of rows:100 - Select Operator [SEL_21] (rows=348477374 width=88) - Output:["_col0","_col1","_col2","_col3"] - <-Reducer 4 [SIMPLE_EDGE] - SHUFFLE [RS_20] - Select Operator [SEL_19] (rows=348477374 width=88) - Output:["_col1","_col2","_col3"] + File Output Operator [FS_24] + Select Operator [SEL_23] (rows=100 width=88) + Output:["_col0","_col1","_col2","_col3"] + Limit [LIM_22] (rows=100 width=88) + Number of rows:100 + Select Operator [SEL_21] (rows=348477374 width=88) + Output:["_col0","_col1","_col2"] + <-Reducer 4 [SIMPLE_EDGE] + SHUFFLE [RS_20] Group By Operator [GBY_18] (rows=348477374 width=88) Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1 <-Reducer 3 [SIMPLE_EDGE] @@ -31,28 +31,28 @@ Stage-0 PartitionCols:_col0, _col1 Group By Operator [GBY_16] (rows=696954748 width=88) Output:["_col0","_col1","_col2"],aggregations:["sum(_col2)"],keys:_col7, _col8 - Merge Join Operator [MERGEJOIN_33] (rows=696954748 width=88) + Merge Join Operator [MERGEJOIN_34] (rows=696954748 width=88) Conds:RS_12._col1=RS_13._col0(Inner),Output:["_col2","_col7","_col8"] <-Map 7 [SIMPLE_EDGE] SHUFFLE [RS_13] PartitionCols:_col0 Select Operator [SEL_8] (rows=231000 width=1436) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_31] (rows=231000 width=1436) + Filter Operator [FIL_32] (rows=231000 width=1436) predicate:((i_manager_id = 1) and i_item_sk is not null) TableScan [TS_6] (rows=462000 width=1436) default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_category_id","i_category","i_manager_id"] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_12] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_32] (rows=633595212 width=88) + Merge Join Operator [MERGEJOIN_33] (rows=633595212 width=88) Conds:RS_9._col0=RS_10._col0(Inner),Output:["_col1","_col2"] <-Map 1 [SIMPLE_EDGE] SHUFFLE [RS_9] PartitionCols:_col0 Select Operator [SEL_2] (rows=575995635 width=88) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_29] (rows=575995635 width=88) + Filter Operator [FIL_30] (rows=575995635 width=88) predicate:(ss_sold_date_sk is not null and ss_item_sk is not null) TableScan [TS_0] (rows=575995635 width=88) default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_ext_sales_price"] @@ -61,7 +61,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_5] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_30] (rows=18262 width=1119) + Filter Operator [FIL_31] (rows=18262 width=1119) predicate:((d_moy = 12) and (d_year = 1998) and d_date_sk is not null) TableScan [TS_3] (rows=73049 width=1119) default@date_dim,dt,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"] http://git-wip-us.apache.org/repos/asf/hive/blob/a74c1e7c/ql/src/test/results/clientpositive/perf/query52.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/query52.q.out b/ql/src/test/results/clientpositive/perf/query52.q.out index 74ecaf2..3d4b9e5 100644 --- a/ql/src/test/results/clientpositive/perf/query52.q.out +++ b/ql/src/test/results/clientpositive/perf/query52.q.out @@ -12,18 +12,18 @@ Reducer 5 <- Reducer 4 (SIMPLE_EDGE) Stage-0 Fetch Operator - limit:100 + limit:-1 Stage-1 Reducer 5 - File Output Operator [FS_24] - Limit [LIM_23] (rows=100 width=88) - Number of rows:100 - Select Operator [SEL_22] (rows=348477374 width=88) - Output:["_col0","_col1","_col2","_col3"] - <-Reducer 4 [SIMPLE_EDGE] - SHUFFLE [RS_21] - Select Operator [SEL_19] (rows=348477374 width=88) - Output:["_col1","_col2","_col3"] + File Output Operator [FS_25] + Select Operator [SEL_24] (rows=100 width=88) + Output:["_col0","_col1","_col2","_col3"] + Limit [LIM_23] (rows=100 width=88) + Number of rows:100 + Select Operator [SEL_22] (rows=348477374 width=88) + Output:["_col0","_col1","_col2"] + <-Reducer 4 [SIMPLE_EDGE] + SHUFFLE [RS_21] Group By Operator [GBY_18] (rows=348477374 width=88) Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0, KEY._col1 <-Reducer 3 [SIMPLE_EDGE] @@ -31,28 +31,28 @@ Stage-0 PartitionCols:_col0, _col1 Group By Operator [GBY_16] (rows=696954748 width=88) Output:["_col0","_col1","_col2"],aggregations:["sum(_col2)"],keys:_col7, _col8 - Merge Join Operator [MERGEJOIN_34] (rows=696954748 width=88) + Merge Join Operator [MERGEJOIN_35] (rows=696954748 width=88) Conds:RS_12._col1=RS_13._col0(Inner),Output:["_col2","_col7","_col8"] <-Map 7 [SIMPLE_EDGE] SHUFFLE [RS_13] PartitionCols:_col0 Select Operator [SEL_8] (rows=231000 width=1436) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_32] (rows=231000 width=1436) + Filter Operator [FIL_33] (rows=231000 width=1436) predicate:((i_manager_id = 1) and i_item_sk is not null) TableScan [TS_6] (rows=462000 width=1436) default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_brand_id","i_brand","i_manager_id"] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_12] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_33] (rows=633595212 width=88) + Merge Join Operator [MERGEJOIN_34] (rows=633595212 width=88) Conds:RS_9._col0=RS_10._col0(Inner),Output:["_col1","_col2"] <-Map 1 [SIMPLE_EDGE] SHUFFLE [RS_9] PartitionCols:_col0 Select Operator [SEL_2] (rows=575995635 width=88) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_30] (rows=575995635 width=88) + Filter Operator [FIL_31] (rows=575995635 width=88) predicate:(ss_sold_date_sk is not null and ss_item_sk is not null) TableScan [TS_0] (rows=575995635 width=88) default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_ext_sales_price"] @@ -61,7 +61,7 @@ Stage-0 PartitionCols:_col0 Select Operator [SEL_5] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_31] (rows=18262 width=1119) + Filter Operator [FIL_32] (rows=18262 width=1119) predicate:((d_moy = 12) and (d_year = 1998) and d_date_sk is not null) TableScan [TS_3] (rows=73049 width=1119) default@date_dim,dt,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"]
