http://git-wip-us.apache.org/repos/asf/hive/blob/e8f283cf/ql/src/test/results/clientpositive/perf/tez/query49.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query49.q.out b/ql/src/test/results/clientpositive/perf/tez/query49.q.out index 3a9c640..47f37a2 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query49.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query49.q.out @@ -277,44 +277,44 @@ Stage-0 limit:100 Stage-1 Reducer 11 vectorized - File Output Operator [FS_179] - Limit [LIM_178] (rows=100 width=101) + File Output Operator [FS_205] + Limit [LIM_204] (rows=100 width=101) Number of rows:100 - Select Operator [SEL_177] (rows=5915494 width=101) + Select Operator [SEL_203] (rows=5915494 width=101) Output:["_col0","_col1","_col2","_col3","_col4"] <-Reducer 10 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_176] - Select Operator [SEL_175] (rows=5915494 width=101) + SHUFFLE [RS_202] + Select Operator [SEL_201] (rows=5915494 width=101) Output:["_col0","_col1","_col2","_col3","_col4"] - Group By Operator [GBY_174] (rows=5915494 width=101) + Group By Operator [GBY_200] (rows=5915494 width=101) Output:["_col0","_col1","_col2","_col3","_col4"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4 <-Union 9 [SIMPLE_EDGE] <-Reducer 22 [CONTAINS] vectorized - Reduce Output Operator [RS_215] + Reduce Output Operator [RS_241] PartitionCols:_col0, _col1, _col2, _col3, _col4 - Group By Operator [GBY_214] (rows=11830988 width=101) + Group By Operator [GBY_240] (rows=11830988 width=101) Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2 - Select Operator [SEL_213] (rows=8604378 width=88) + Select Operator [SEL_239] (rows=8604378 width=88) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_212] (rows=8604378 width=88) + Filter Operator [FIL_238] (rows=8604378 width=88) predicate:((_col0 <= 10) or (rank_window_1 <= 10)) - PTF Operator [PTF_211] (rows=12906568 width=88) + PTF Operator [PTF_237] (rows=12906568 width=88) Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}] - Select Operator [SEL_210] (rows=12906568 width=88) + Select Operator [SEL_236] (rows=12906568 width=88) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] <-Reducer 21 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_209] + SHUFFLE [RS_235] PartitionCols:0 - Select Operator [SEL_208] (rows=12906568 width=88) + Select Operator [SEL_234] (rows=12906568 width=88) Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"] - PTF Operator [PTF_207] (rows=12906568 width=88) + PTF Operator [PTF_233] (rows=12906568 width=88) Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}] - Select Operator [SEL_206] (rows=12906568 width=88) + Select Operator [SEL_232] (rows=12906568 width=88) Output:["_col0","_col1","_col2","_col3","_col4"] <-Reducer 20 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_205] + SHUFFLE [RS_231] PartitionCols:0 - Group By Operator [GBY_204] (rows=12906568 width=88) + Group By Operator [GBY_230] (rows=12906568 width=88) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0 <-Reducer 19 [SIMPLE_EDGE] SHUFFLE [RS_89] @@ -324,13 +324,13 @@ Stage-0 Select Operator [SEL_86] (rows=25813137 width=88) Output:["_col0","_col1","_col2","_col3","_col4"] Merge Join Operator [MERGEJOIN_146] (rows=25813137 width=88) - Conds:RS_83._col1, _col2=RS_203._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"] + Conds:RS_83._col1, _col2=RS_229._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"] <-Map 27 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_203] + SHUFFLE [RS_229] PartitionCols:_col0, _col1 - Select Operator [SEL_202] (rows=19197050 width=77) + Select Operator [SEL_228] (rows=19197050 width=77) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_201] (rows=19197050 width=77) + Filter Operator [FIL_227] (rows=19197050 width=77) predicate:((sr_return_amt > 10000) and sr_item_sk is not null and sr_ticket_number is not null) TableScan [TS_77] (rows=57591150 width=77) default@store_returns,sr,Tbl:COMPLETE,Col:NONE,Output:["sr_item_sk","sr_ticket_number","sr_return_quantity","sr_return_amt"] @@ -338,61 +338,61 @@ Stage-0 SHUFFLE [RS_83] PartitionCols:_col1, _col2 Merge Join Operator [MERGEJOIN_145] (rows=23466488 width=88) - Conds:RS_200._col0=RS_154._col0(Inner),Output:["_col1","_col2","_col3","_col4"] + Conds:RS_226._col0=RS_180._col0(Inner),Output:["_col1","_col2","_col3","_col4"] <-Map 12 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_154] + SHUFFLE [RS_180] PartitionCols:_col0 - Select Operator [SEL_151] (rows=18262 width=1119) + Select Operator [SEL_177] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_150] (rows=18262 width=1119) + Filter Operator [FIL_176] (rows=18262 width=1119) predicate:((d_moy = 12) and (d_year = 2000) 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"] <-Map 26 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_200] + SHUFFLE [RS_226] PartitionCols:_col0 - Select Operator [SEL_199] (rows=21333171 width=88) + Select Operator [SEL_225] (rows=21333171 width=88) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_198] (rows=21333171 width=88) + Filter Operator [FIL_224] (rows=21333171 width=88) predicate:((ss_net_paid > 0) and (ss_net_profit > 1) and (ss_quantity > 0) and ss_item_sk is not null and ss_sold_date_sk is not null and ss_ticket_number is not null) TableScan [TS_71] (rows=575995635 width=88) default@store_sales,sts,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_ticket_number","ss_quantity","ss_net_paid","ss_net_profit"] <-Reducer 8 [CONTAINS] vectorized - Reduce Output Operator [RS_173] + Reduce Output Operator [RS_199] PartitionCols:_col0, _col1, _col2, _col3, _col4 - Group By Operator [GBY_172] (rows=11830988 width=101) + Group By Operator [GBY_198] (rows=11830988 width=101) Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2 - Select Operator [SEL_171] (rows=3226610 width=135) + Select Operator [SEL_197] (rows=3226610 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] - Group By Operator [GBY_170] (rows=3226610 width=135) + Group By Operator [GBY_196] (rows=3226610 width=135) Output:["_col0","_col1","_col2","_col3","_col4"],keys:KEY._col0, KEY._col1, KEY._col2, KEY._col3, KEY._col4 <-Union 7 [SIMPLE_EDGE] <-Reducer 17 [CONTAINS] vectorized - Reduce Output Operator [RS_197] + Reduce Output Operator [RS_223] PartitionCols:_col0, _col1, _col2, _col3, _col4 - Group By Operator [GBY_196] (rows=6453220 width=135) + Group By Operator [GBY_222] (rows=6453220 width=135) Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2 - Select Operator [SEL_195] (rows=4302070 width=135) + Select Operator [SEL_221] (rows=4302070 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_194] (rows=4302070 width=135) + Filter Operator [FIL_220] (rows=4302070 width=135) predicate:((_col0 <= 10) or (rank_window_1 <= 10)) - PTF Operator [PTF_193] (rows=6453105 width=135) + PTF Operator [PTF_219] (rows=6453105 width=135) Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}] - Select Operator [SEL_192] (rows=6453105 width=135) + Select Operator [SEL_218] (rows=6453105 width=135) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] <-Reducer 16 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_191] + SHUFFLE [RS_217] PartitionCols:0 - Select Operator [SEL_190] (rows=6453105 width=135) + Select Operator [SEL_216] (rows=6453105 width=135) Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"] - PTF Operator [PTF_189] (rows=6453105 width=135) + PTF Operator [PTF_215] (rows=6453105 width=135) Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}] - Select Operator [SEL_188] (rows=6453105 width=135) + Select Operator [SEL_214] (rows=6453105 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] <-Reducer 15 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_187] + SHUFFLE [RS_213] PartitionCols:0 - Group By Operator [GBY_186] (rows=6453105 width=135) + Group By Operator [GBY_212] (rows=6453105 width=135) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0 <-Reducer 14 [SIMPLE_EDGE] SHUFFLE [RS_50] @@ -402,13 +402,13 @@ Stage-0 Select Operator [SEL_47] (rows=12906211 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] Merge Join Operator [MERGEJOIN_144] (rows=12906211 width=135) - Conds:RS_44._col1, _col2=RS_185._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"] + Conds:RS_44._col1, _col2=RS_211._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"] <-Map 25 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_185] + SHUFFLE [RS_211] PartitionCols:_col0, _col1 - Select Operator [SEL_184] (rows=9599627 width=106) + Select Operator [SEL_210] (rows=9599627 width=106) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_183] (rows=9599627 width=106) + Filter Operator [FIL_209] (rows=9599627 width=106) predicate:((cr_return_amount > 10000) and cr_item_sk is not null and cr_order_number is not null) TableScan [TS_38] (rows=28798881 width=106) default@catalog_returns,cr,Tbl:COMPLETE,Col:NONE,Output:["cr_item_sk","cr_order_number","cr_return_quantity","cr_return_amount"] @@ -416,46 +416,46 @@ Stage-0 SHUFFLE [RS_44] PartitionCols:_col1, _col2 Merge Join Operator [MERGEJOIN_143] (rows=11732919 width=135) - Conds:RS_182._col0=RS_153._col0(Inner),Output:["_col1","_col2","_col3","_col4"] + Conds:RS_208._col0=RS_179._col0(Inner),Output:["_col1","_col2","_col3","_col4"] <-Map 12 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_153] + SHUFFLE [RS_179] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_151] + Please refer to the previous Select Operator [SEL_177] <-Map 24 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_182] + SHUFFLE [RS_208] PartitionCols:_col0 - Select Operator [SEL_181] (rows=10666290 width=135) + Select Operator [SEL_207] (rows=10666290 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_180] (rows=10666290 width=135) + Filter Operator [FIL_206] (rows=10666290 width=135) predicate:((cs_net_paid > 0) and (cs_net_profit > 1) and (cs_quantity > 0) and cs_item_sk is not null and cs_order_number is not null and cs_sold_date_sk is not null) TableScan [TS_32] (rows=287989836 width=135) default@catalog_sales,cs,Tbl:COMPLETE,Col:NONE,Output:["cs_sold_date_sk","cs_item_sk","cs_order_number","cs_quantity","cs_net_paid","cs_net_profit"] <-Reducer 6 [CONTAINS] vectorized - Reduce Output Operator [RS_169] + Reduce Output Operator [RS_195] PartitionCols:_col0, _col1, _col2, _col3, _col4 - Group By Operator [GBY_168] (rows=6453220 width=135) + Group By Operator [GBY_194] (rows=6453220 width=135) Output:["_col0","_col1","_col2","_col3","_col4"],keys:_col0, _col3, _col4, _col1, _col2 - Select Operator [SEL_167] (rows=2151150 width=135) + Select Operator [SEL_193] (rows=2151150 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_166] (rows=2151150 width=135) + Filter Operator [FIL_192] (rows=2151150 width=135) predicate:((_col0 <= 10) or (rank_window_1 <= 10)) - PTF Operator [PTF_165] (rows=3226726 width=135) + PTF Operator [PTF_191] (rows=3226726 width=135) Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col4 AS decimal(15,4)) / CAST( _col5 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}] - Select Operator [SEL_164] (rows=3226726 width=135) + Select Operator [SEL_190] (rows=3226726 width=135) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] <-Reducer 5 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_163] + SHUFFLE [RS_189] PartitionCols:0 - Select Operator [SEL_162] (rows=3226726 width=135) + Select Operator [SEL_188] (rows=3226726 width=135) Output:["rank_window_0","_col0","_col1","_col2","_col3","_col4"] - PTF Operator [PTF_161] (rows=3226726 width=135) + PTF Operator [PTF_187] (rows=3226726 width=135) Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(CAST( _col1 AS decimal(15,4)) / CAST( _col2 AS decimal(15,4))) ASC NULLS FIRST","partition by:":"0"}] - Select Operator [SEL_160] (rows=3226726 width=135) + Select Operator [SEL_186] (rows=3226726 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] <-Reducer 4 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_159] + SHUFFLE [RS_185] PartitionCols:0 - Group By Operator [GBY_158] (rows=3226726 width=135) + Group By Operator [GBY_184] (rows=3226726 width=135) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0 <-Reducer 3 [SIMPLE_EDGE] SHUFFLE [RS_18] @@ -465,13 +465,13 @@ Stage-0 Select Operator [SEL_15] (rows=6453452 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] Merge Join Operator [MERGEJOIN_142] (rows=6453452 width=135) - Conds:RS_12._col1, _col2=RS_157._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"] + Conds:RS_12._col1, _col2=RS_183._col0, _col1(Inner),Output:["_col1","_col3","_col4","_col11","_col12"] <-Map 23 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_157] + SHUFFLE [RS_183] PartitionCols:_col0, _col1 - Select Operator [SEL_156] (rows=4799489 width=92) + Select Operator [SEL_182] (rows=4799489 width=92) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_155] (rows=4799489 width=92) + Filter Operator [FIL_181] (rows=4799489 width=92) predicate:((wr_return_amt > 10000) and wr_item_sk is not null and wr_order_number is not null) TableScan [TS_6] (rows=14398467 width=92) default@web_returns,wr,Tbl:COMPLETE,Col:NONE,Output:["wr_item_sk","wr_order_number","wr_return_quantity","wr_return_amt"] @@ -479,17 +479,17 @@ Stage-0 SHUFFLE [RS_12] PartitionCols:_col1, _col2 Merge Join Operator [MERGEJOIN_141] (rows=5866775 width=135) - Conds:RS_149._col0=RS_152._col0(Inner),Output:["_col1","_col2","_col3","_col4"] + Conds:RS_175._col0=RS_178._col0(Inner),Output:["_col1","_col2","_col3","_col4"] <-Map 12 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_152] + SHUFFLE [RS_178] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_151] + Please refer to the previous Select Operator [SEL_177] <-Map 1 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_149] + SHUFFLE [RS_175] PartitionCols:_col0 - Select Operator [SEL_148] (rows=5333432 width=135) + Select Operator [SEL_174] (rows=5333432 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_147] (rows=5333432 width=135) + Filter Operator [FIL_173] (rows=5333432 width=135) predicate:((ws_net_paid > 0) and (ws_net_profit > 1) and (ws_quantity > 0) and ws_item_sk is not null and ws_order_number is not null and ws_sold_date_sk is not null) TableScan [TS_0] (rows=144002668 width=135) default@web_sales,ws,Tbl:COMPLETE,Col:NONE,Output:["ws_sold_date_sk","ws_item_sk","ws_order_number","ws_quantity","ws_net_paid","ws_net_profit"]
http://git-wip-us.apache.org/repos/asf/hive/blob/e8f283cf/ql/src/test/results/clientpositive/perf/tez/query5.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query5.q.out b/ql/src/test/results/clientpositive/perf/tez/query5.q.out index f13b767..f074ed1 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query5.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query5.q.out @@ -278,26 +278,26 @@ Stage-0 limit:100 Stage-1 Reducer 8 vectorized - File Output Operator [FS_158] - Limit [LIM_157] (rows=100 width=110) + File Output Operator [FS_202] + Limit [LIM_201] (rows=100 width=110) Number of rows:100 - Select Operator [SEL_156] (rows=1136898901 width=110) + Select Operator [SEL_200] (rows=1136898901 width=110) Output:["_col0","_col1","_col2","_col3","_col4"] <-Reducer 7 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_155] - Select Operator [SEL_154] (rows=1136898901 width=110) + SHUFFLE [RS_199] + Select Operator [SEL_198] (rows=1136898901 width=110) Output:["_col0","_col1","_col2","_col3","_col4"] - Group By Operator [GBY_153] (rows=1136898901 width=110) + Group By Operator [GBY_197] (rows=1136898901 width=110) Output:["_col0","_col1","_col3","_col4","_col5"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)"],keys:KEY._col0, KEY._col1, KEY._col2 <-Union 6 [SIMPLE_EDGE] <-Reducer 13 [CONTAINS] vectorized - Reduce Output Operator [RS_168] + Reduce Output Operator [RS_212] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_167] (rows=2273797803 width=110) + Group By Operator [GBY_211] (rows=2273797803 width=110) Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0, _col1, 0L - Select Operator [SEL_166] (rows=191657181 width=132) + Select Operator [SEL_210] (rows=191657181 width=132) Output:["_col0","_col1","_col2","_col3","_col4"] - Group By Operator [GBY_165] (rows=191657181 width=132) + Group By Operator [GBY_209] (rows=191657181 width=132) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0 <-Reducer 12 [SIMPLE_EDGE] SHUFFLE [RS_47] @@ -305,13 +305,13 @@ Stage-0 Group By Operator [GBY_46] (rows=383314363 width=132) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col2)","sum(_col4)","sum(_col3)","sum(_col5)"],keys:_col9 Merge Join Operator [MERGEJOIN_135] (rows=383314363 width=132) - Conds:RS_42._col0=RS_164._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9"] + Conds:RS_42._col0=RS_208._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9"] <-Map 21 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_164] + SHUFFLE [RS_208] PartitionCols:_col0 - Select Operator [SEL_163] (rows=46000 width=460) + Select Operator [SEL_207] (rows=46000 width=460) Output:["_col0","_col1"] - Filter Operator [FIL_162] (rows=46000 width=460) + Filter Operator [FIL_206] (rows=46000 width=460) predicate:cp_catalog_page_sk is not null TableScan [TS_36] (rows=46000 width=460) default@catalog_page,catalog_page,Tbl:COMPLETE,Col:NONE,Output:["cp_catalog_page_sk","cp_catalog_page_id"] @@ -319,43 +319,43 @@ Stage-0 SHUFFLE [RS_42] PartitionCols:_col0 Merge Join Operator [MERGEJOIN_134] (rows=348467596 width=132) - Conds:Union 19._col1=RS_144._col0(Inner),Output:["_col0","_col2","_col3","_col4","_col5"] + Conds:Union 19._col1=RS_188._col0(Inner),Output:["_col0","_col2","_col3","_col4","_col5"] <-Map 10 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_144] + SHUFFLE [RS_188] PartitionCols:_col0 - Select Operator [SEL_142] (rows=8116 width=1119) + Select Operator [SEL_186] (rows=8116 width=1119) Output:["_col0"] - Filter Operator [FIL_141] (rows=8116 width=1119) + Filter Operator [FIL_185] (rows=8116 width=1119) predicate:(CAST( d_date AS TIMESTAMP) BETWEEN TIMESTAMP'1998-08-04 00:00:00.0' AND TIMESTAMP'1998-08-18 00:00:00.0' and d_date_sk is not null) TableScan [TS_8] (rows=73049 width=1119) default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_date"] <-Union 19 [SIMPLE_EDGE] <-Map 18 [CONTAINS] vectorized - Reduce Output Operator [RS_178] + Reduce Output Operator [RS_222] PartitionCols:_col1 - Select Operator [SEL_177] (rows=287989836 width=135) + Select Operator [SEL_221] (rows=287989836 width=135) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_176] (rows=287989836 width=135) + Filter Operator [FIL_220] (rows=287989836 width=135) predicate:(cs_catalog_page_sk is not null and cs_sold_date_sk is not null) - TableScan [TS_25] (rows=287989836 width=135) + TableScan [TS_163] (rows=287989836 width=135) Output:["cs_sold_date_sk","cs_catalog_page_sk","cs_ext_sales_price","cs_net_profit"] <-Map 20 [CONTAINS] vectorized - Reduce Output Operator [RS_181] + Reduce Output Operator [RS_225] PartitionCols:_col1 - Select Operator [SEL_180] (rows=28798881 width=106) + Select Operator [SEL_224] (rows=28798881 width=106) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_179] (rows=28798881 width=106) + Filter Operator [FIL_223] (rows=28798881 width=106) predicate:(cr_catalog_page_sk is not null and cr_returned_date_sk is not null) - TableScan [TS_28] (rows=28798881 width=106) + TableScan [TS_168] (rows=28798881 width=106) Output:["cr_returned_date_sk","cr_catalog_page_sk","cr_return_amount","cr_net_loss"] <-Reducer 16 [CONTAINS] vectorized - Reduce Output Operator [RS_175] + Reduce Output Operator [RS_219] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_174] (rows=2273797803 width=110) + Group By Operator [GBY_218] (rows=2273797803 width=110) Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0, _col1, 0L - Select Operator [SEL_173] (rows=182955399 width=135) + Select Operator [SEL_217] (rows=182955399 width=135) Output:["_col0","_col1","_col2","_col3","_col4"] - Group By Operator [GBY_172] (rows=182955399 width=135) + Group By Operator [GBY_216] (rows=182955399 width=135) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0 <-Reducer 15 [SIMPLE_EDGE] SHUFFLE [RS_80] @@ -363,13 +363,13 @@ Stage-0 Group By Operator [GBY_79] (rows=365910798 width=135) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col2)","sum(_col4)","sum(_col3)","sum(_col5)"],keys:_col9 Merge Join Operator [MERGEJOIN_137] (rows=365910798 width=135) - Conds:RS_75._col0=RS_171._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9"] + Conds:RS_75._col0=RS_215._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9"] <-Map 27 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_171] + SHUFFLE [RS_215] PartitionCols:_col0 - Select Operator [SEL_170] (rows=84 width=1850) + Select Operator [SEL_214] (rows=84 width=1850) Output:["_col0","_col1"] - Filter Operator [FIL_169] (rows=84 width=1850) + Filter Operator [FIL_213] (rows=84 width=1850) predicate:web_site_sk is not null TableScan [TS_69] (rows=84 width=1850) default@web_site,web_site,Tbl:COMPLETE,Col:NONE,Output:["web_site_sk","web_site_id"] @@ -377,54 +377,54 @@ Stage-0 SHUFFLE [RS_75] PartitionCols:_col0 Merge Join Operator [MERGEJOIN_136] (rows=332646173 width=135) - Conds:Union 23._col1=RS_145._col0(Inner),Output:["_col0","_col2","_col3","_col4","_col5"] + Conds:Union 23._col1=RS_189._col0(Inner),Output:["_col0","_col2","_col3","_col4","_col5"] <-Map 10 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_145] + SHUFFLE [RS_189] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_142] + Please refer to the previous Select Operator [SEL_186] <-Union 23 [SIMPLE_EDGE] <-Map 22 [CONTAINS] vectorized - Reduce Output Operator [RS_184] + Reduce Output Operator [RS_228] PartitionCols:_col1 - Select Operator [SEL_183] (rows=144002668 width=135) + Select Operator [SEL_227] (rows=144002668 width=135) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_182] (rows=144002668 width=135) + Filter Operator [FIL_226] (rows=144002668 width=135) predicate:(ws_sold_date_sk is not null and ws_web_site_sk is not null) - TableScan [TS_51] (rows=144002668 width=135) + TableScan [TS_173] (rows=144002668 width=135) Output:["ws_sold_date_sk","ws_web_site_sk","ws_ext_sales_price","ws_net_profit"] <-Reducer 25 [CONTAINS] - Reduce Output Operator [RS_72] + Reduce Output Operator [RS_181] PartitionCols:_col1 - Select Operator [SEL_63] (rows=158402938 width=135) + Select Operator [SEL_179] (rows=158402938 width=135) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Merge Join Operator [MERGEJOIN_131] (rows=158402938 width=135) - Conds:RS_187._col0, _col2=RS_190._col1, _col2(Inner),Output:["_col1","_col3","_col6","_col7"] + Merge Join Operator [MERGEJOIN_178] (rows=158402938 width=135) + Conds:RS_231._col0, _col2=RS_234._col1, _col2(Inner),Output:["_col1","_col3","_col6","_col7"] <-Map 24 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_187] + SHUFFLE [RS_231] PartitionCols:_col0, _col2 - Select Operator [SEL_186] (rows=144002668 width=135) + Select Operator [SEL_230] (rows=144002668 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_185] (rows=144002668 width=135) + Filter Operator [FIL_229] (rows=144002668 width=135) predicate:(ws_item_sk is not null and ws_order_number is not null and ws_web_site_sk is not null) TableScan [TS_54] (rows=144002668 width=135) default@web_sales,web_sales,Tbl:COMPLETE,Col:NONE,Output:["ws_item_sk","ws_web_site_sk","ws_order_number"] <-Map 26 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_190] + SHUFFLE [RS_234] PartitionCols:_col1, _col2 - Select Operator [SEL_189] (rows=14398467 width=92) + Select Operator [SEL_233] (rows=14398467 width=92) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_188] (rows=14398467 width=92) + Filter Operator [FIL_232] (rows=14398467 width=92) predicate:(wr_item_sk is not null and wr_order_number is not null and wr_returned_date_sk is not null) TableScan [TS_57] (rows=14398467 width=92) default@web_returns,web_returns,Tbl:COMPLETE,Col:NONE,Output:["wr_returned_date_sk","wr_item_sk","wr_order_number","wr_return_amt","wr_net_loss"] <-Reducer 5 [CONTAINS] vectorized - Reduce Output Operator [RS_152] + Reduce Output Operator [RS_196] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_151] (rows=2273797803 width=110) + Group By Operator [GBY_195] (rows=2273797803 width=110) Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["sum(_col2)","sum(_col3)","sum(_col4)"],keys:_col0, _col1, 0L - Select Operator [SEL_150] (rows=383320021 width=87) + Select Operator [SEL_194] (rows=383320021 width=87) Output:["_col0","_col1","_col2","_col3","_col4"] - Group By Operator [GBY_149] (rows=383320021 width=87) + Group By Operator [GBY_193] (rows=383320021 width=87) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)","sum(VALUE._col2)","sum(VALUE._col3)"],keys:KEY._col0 <-Reducer 4 [SIMPLE_EDGE] SHUFFLE [RS_22] @@ -432,13 +432,13 @@ Stage-0 Group By Operator [GBY_21] (rows=766640042 width=87) Output:["_col0","_col1","_col2","_col3","_col4"],aggregations:["sum(_col2)","sum(_col4)","sum(_col3)","sum(_col5)"],keys:_col9 Merge Join Operator [MERGEJOIN_133] (rows=766640042 width=87) - Conds:RS_17._col0=RS_148._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9"] + Conds:RS_17._col0=RS_192._col0(Inner),Output:["_col2","_col3","_col4","_col5","_col9"] <-Map 17 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_148] + SHUFFLE [RS_192] PartitionCols:_col0 - Select Operator [SEL_147] (rows=1704 width=1910) + Select Operator [SEL_191] (rows=1704 width=1910) Output:["_col0","_col1"] - Filter Operator [FIL_146] (rows=1704 width=1910) + Filter Operator [FIL_190] (rows=1704 width=1910) predicate:s_store_sk is not null TableScan [TS_11] (rows=1704 width=1910) default@store,store,Tbl:COMPLETE,Col:NONE,Output:["s_store_sk","s_store_id"] @@ -446,28 +446,28 @@ Stage-0 SHUFFLE [RS_17] PartitionCols:_col0 Merge Join Operator [MERGEJOIN_132] (rows=696945478 width=87) - Conds:Union 2._col1=RS_143._col0(Inner),Output:["_col0","_col2","_col3","_col4","_col5"] + Conds:Union 2._col1=RS_187._col0(Inner),Output:["_col0","_col2","_col3","_col4","_col5"] <-Map 10 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_143] + SHUFFLE [RS_187] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_142] + Please refer to the previous Select Operator [SEL_186] <-Union 2 [SIMPLE_EDGE] <-Map 1 [CONTAINS] vectorized - Reduce Output Operator [RS_140] + Reduce Output Operator [RS_184] PartitionCols:_col1 - Select Operator [SEL_139] (rows=575995635 width=88) + Select Operator [SEL_183] (rows=575995635 width=88) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_138] (rows=575995635 width=88) + Filter Operator [FIL_182] (rows=575995635 width=88) predicate:(ss_sold_date_sk is not null and ss_store_sk is not null) - TableScan [TS_0] (rows=575995635 width=88) + TableScan [TS_138] (rows=575995635 width=88) Output:["ss_sold_date_sk","ss_store_sk","ss_ext_sales_price","ss_net_profit"] <-Map 9 [CONTAINS] vectorized - Reduce Output Operator [RS_161] + Reduce Output Operator [RS_205] PartitionCols:_col1 - Select Operator [SEL_160] (rows=57591150 width=77) + Select Operator [SEL_204] (rows=57591150 width=77) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_159] (rows=57591150 width=77) + Filter Operator [FIL_203] (rows=57591150 width=77) predicate:(sr_returned_date_sk is not null and sr_store_sk is not null) - TableScan [TS_3] (rows=57591150 width=77) + TableScan [TS_148] (rows=57591150 width=77) Output:["sr_returned_date_sk","sr_store_sk","sr_return_amt","sr_net_loss"] http://git-wip-us.apache.org/repos/asf/hive/blob/e8f283cf/ql/src/test/results/clientpositive/perf/tez/query54.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/perf/tez/query54.q.out b/ql/src/test/results/clientpositive/perf/tez/query54.q.out index 699adb8..386ea4b 100644 --- a/ql/src/test/results/clientpositive/perf/tez/query54.q.out +++ b/ql/src/test/results/clientpositive/perf/tez/query54.q.out @@ -143,25 +143,25 @@ Stage-0 limit:100 Stage-1 Reducer 9 vectorized - File Output Operator [FS_249] - Limit [LIM_248] (rows=100 width=158) + File Output Operator [FS_259] + Limit [LIM_258] (rows=100 width=158) Number of rows:100 - Select Operator [SEL_247] (rows=1614130953450400 width=158) + Select Operator [SEL_257] (rows=1614130953450400 width=158) Output:["_col0","_col1","_col2"] <-Reducer 8 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_246] - Select Operator [SEL_245] (rows=1614130953450400 width=158) + SHUFFLE [RS_256] + Select Operator [SEL_255] (rows=1614130953450400 width=158) Output:["_col0","_col1","_col2"] - Group By Operator [GBY_244] (rows=1614130953450400 width=158) + Group By Operator [GBY_254] (rows=1614130953450400 width=158) Output:["_col0","_col1"],aggregations:["count(VALUE._col0)"],keys:KEY._col0 <-Reducer 7 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_243] + SHUFFLE [RS_253] PartitionCols:_col0 - Group By Operator [GBY_242] (rows=3228261906900801 width=158) + Group By Operator [GBY_252] (rows=3228261906900801 width=158) Output:["_col0","_col1"],aggregations:["count()"],keys:_col0 - Select Operator [SEL_241] (rows=3228261906900801 width=158) + Select Operator [SEL_251] (rows=3228261906900801 width=158) Output:["_col0"] - Group By Operator [GBY_240] (rows=3228261906900801 width=158) + Group By Operator [GBY_250] (rows=3228261906900801 width=158) Output:["_col0","_col1"],aggregations:["sum(VALUE._col0)"],keys:KEY._col0 <-Reducer 6 [SIMPLE_EDGE] SHUFFLE [RS_119] @@ -181,42 +181,42 @@ Stage-0 Merge Join Operator [MERGEJOIN_183] (rows=9131 width=1128) Conds:(Right Outer),Output:["_col0"] <-Reducer 28 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_231] - Group By Operator [GBY_230] (rows=9131 width=1119) + PARTITION_ONLY_SHUFFLE [RS_241] + Group By Operator [GBY_240] (rows=9131 width=1119) Output:["_col0"],keys:KEY._col0 <-Map 25 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_219] + SHUFFLE [RS_229] PartitionCols:_col0 - Group By Operator [GBY_216] (rows=18262 width=1119) + Group By Operator [GBY_226] (rows=18262 width=1119) Output:["_col0"],keys:_col0 - Select Operator [SEL_213] (rows=18262 width=1119) + Select Operator [SEL_223] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_211] (rows=18262 width=1119) + Filter Operator [FIL_221] (rows=18262 width=1119) predicate:((d_moy = 3) and (d_year = 1999)) TableScan [TS_73] (rows=73049 width=1119) default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_month_seq","d_year","d_moy"] <-Reducer 31 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_239] - Select Operator [SEL_238] (rows=1 width=8) - Filter Operator [FIL_237] (rows=1 width=8) + PARTITION_ONLY_SHUFFLE [RS_249] + Select Operator [SEL_248] (rows=1 width=8) + Filter Operator [FIL_247] (rows=1 width=8) predicate:(sq_count_check(_col0) <= 1) - Group By Operator [GBY_236] (rows=1 width=8) + Group By Operator [GBY_246] (rows=1 width=8) Output:["_col0"],aggregations:["count(VALUE._col0)"] <-Reducer 30 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_235] - Group By Operator [GBY_234] (rows=1 width=8) + PARTITION_ONLY_SHUFFLE [RS_245] + Group By Operator [GBY_244] (rows=1 width=8) Output:["_col0"],aggregations:["count()"] - Select Operator [SEL_233] (rows=9131 width=1119) - Group By Operator [GBY_232] (rows=9131 width=1119) + Select Operator [SEL_243] (rows=9131 width=1119) + Group By Operator [GBY_242] (rows=9131 width=1119) Output:["_col0"],keys:KEY._col0 <-Map 25 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_220] + SHUFFLE [RS_230] PartitionCols:_col0 - Group By Operator [GBY_217] (rows=18262 width=1119) + Group By Operator [GBY_227] (rows=18262 width=1119) Output:["_col0"],keys:_col0 - Select Operator [SEL_214] (rows=18262 width=1119) + Select Operator [SEL_224] (rows=18262 width=1119) Output:["_col0"] - Please refer to the previous Filter Operator [FIL_211] + Please refer to the previous Filter Operator [FIL_221] <-Reducer 5 [CUSTOM_SIMPLE_EDGE] PARTITION_ONLY_SHUFFLE [RS_113] Select Operator [SEL_108] (rows=6363893803988 width=1217) @@ -224,34 +224,34 @@ Stage-0 Merge Join Operator [MERGEJOIN_185] (rows=6363893803988 width=1217) Conds:(Left Outer),Output:["_col2","_col4","_col10","_col13"] <-Reducer 26 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_223] - Group By Operator [GBY_221] (rows=9131 width=1119) + PARTITION_ONLY_SHUFFLE [RS_233] + Group By Operator [GBY_231] (rows=9131 width=1119) Output:["_col0"],keys:KEY._col0 <-Map 25 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_218] + SHUFFLE [RS_228] PartitionCols:_col0 - Group By Operator [GBY_215] (rows=18262 width=1119) + Group By Operator [GBY_225] (rows=18262 width=1119) Output:["_col0"],keys:_col0 - Select Operator [SEL_212] (rows=18262 width=1119) + Select Operator [SEL_222] (rows=18262 width=1119) Output:["_col0"] - Please refer to the previous Filter Operator [FIL_211] + Please refer to the previous Filter Operator [FIL_221] <-Reducer 4 [CUSTOM_SIMPLE_EDGE] PARTITION_ONLY_SHUFFLE [RS_105] Merge Join Operator [MERGEJOIN_184] (rows=696954748 width=97) Conds:(Inner),Output:["_col2","_col4","_col10"] <-Reducer 27 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_229] - Select Operator [SEL_228] (rows=1 width=8) - Filter Operator [FIL_227] (rows=1 width=8) + PARTITION_ONLY_SHUFFLE [RS_239] + Select Operator [SEL_238] (rows=1 width=8) + Filter Operator [FIL_237] (rows=1 width=8) predicate:(sq_count_check(_col0) <= 1) - Group By Operator [GBY_226] (rows=1 width=8) + Group By Operator [GBY_236] (rows=1 width=8) Output:["_col0"],aggregations:["count(VALUE._col0)"] <-Reducer 26 [CUSTOM_SIMPLE_EDGE] vectorized - PARTITION_ONLY_SHUFFLE [RS_225] - Group By Operator [GBY_224] (rows=1 width=8) + PARTITION_ONLY_SHUFFLE [RS_235] + Group By Operator [GBY_234] (rows=1 width=8) Output:["_col0"],aggregations:["count()"] - Select Operator [SEL_222] (rows=9131 width=1119) - Please refer to the previous Group By Operator [GBY_221] + Select Operator [SEL_232] (rows=9131 width=1119) + Please refer to the previous Group By Operator [GBY_231] <-Reducer 3 [CUSTOM_SIMPLE_EDGE] PARTITION_ONLY_SHUFFLE [RS_102] Merge Join Operator [MERGEJOIN_182] (rows=696954748 width=88) @@ -260,36 +260,36 @@ Stage-0 SHUFFLE [RS_100] PartitionCols:_col5 Merge Join Operator [MERGEJOIN_181] (rows=316240138 width=135) - Conds:RS_69._col0=RS_210._col1(Inner),Output:["_col5"] + Conds:RS_69._col0=RS_220._col1(Inner),Output:["_col5"] <-Reducer 12 [SIMPLE_EDGE] SHUFFLE [RS_69] PartitionCols:_col0 Merge Join Operator [MERGEJOIN_177] (rows=44000000 width=1014) - Conds:RS_195._col1, _col2=RS_198._col0, _col1(Inner),Output:["_col0"] + Conds:RS_205._col1, _col2=RS_208._col0, _col1(Inner),Output:["_col0"] <-Map 11 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_195] + SHUFFLE [RS_205] PartitionCols:_col1, _col2 - Select Operator [SEL_194] (rows=40000000 width=1014) + Select Operator [SEL_204] (rows=40000000 width=1014) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_193] (rows=40000000 width=1014) + Filter Operator [FIL_203] (rows=40000000 width=1014) predicate:(ca_address_sk is not null and ca_county is not null and ca_state is not null) TableScan [TS_29] (rows=40000000 width=1014) default@customer_address,customer_address,Tbl:COMPLETE,Col:NONE,Output:["ca_address_sk","ca_county","ca_state"] <-Map 14 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_198] + SHUFFLE [RS_208] PartitionCols:_col0, _col1 - Select Operator [SEL_197] (rows=1704 width=1910) + Select Operator [SEL_207] (rows=1704 width=1910) Output:["_col0","_col1"] - Filter Operator [FIL_196] (rows=1704 width=1910) + Filter Operator [FIL_206] (rows=1704 width=1910) predicate:(s_county is not null and s_state is not null) TableScan [TS_32] (rows=1704 width=1910) default@store,store,Tbl:COMPLETE,Col:NONE,Output:["s_county","s_state"] <-Reducer 20 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_210] + SHUFFLE [RS_220] PartitionCols:_col1 - Select Operator [SEL_209] (rows=287491029 width=135) + Select Operator [SEL_219] (rows=287491029 width=135) Output:["_col0","_col1"] - Group By Operator [GBY_208] (rows=287491029 width=135) + Group By Operator [GBY_218] (rows=287491029 width=135) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Reducer 19 [SIMPLE_EDGE] SHUFFLE [RS_63] @@ -297,13 +297,13 @@ Stage-0 Group By Operator [GBY_62] (rows=574982058 width=135) Output:["_col0","_col1"],keys:_col10, _col9 Merge Join Operator [MERGEJOIN_180] (rows=574982058 width=135) - Conds:RS_58._col1=RS_207._col0(Inner),Output:["_col9","_col10"] + Conds:RS_58._col1=RS_217._col0(Inner),Output:["_col9","_col10"] <-Map 24 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_207] + SHUFFLE [RS_217] PartitionCols:_col0 - Select Operator [SEL_206] (rows=80000000 width=860) + Select Operator [SEL_216] (rows=80000000 width=860) Output:["_col0","_col1"] - Filter Operator [FIL_205] (rows=80000000 width=860) + Filter Operator [FIL_215] (rows=80000000 width=860) predicate:(c_current_addr_sk is not null and c_customer_sk is not null) TableScan [TS_49] (rows=80000000 width=860) default@customer,customer,Tbl:COMPLETE,Col:NONE,Output:["c_customer_sk","c_current_addr_sk"] @@ -311,13 +311,13 @@ Stage-0 SHUFFLE [RS_58] PartitionCols:_col1 Merge Join Operator [MERGEJOIN_179] (rows=522710951 width=135) - Conds:RS_55._col2=RS_204._col0(Inner),Output:["_col1"] + Conds:RS_55._col2=RS_214._col0(Inner),Output:["_col1"] <-Map 23 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_204] + SHUFFLE [RS_214] PartitionCols:_col0 - Select Operator [SEL_203] (rows=115500 width=1436) + Select Operator [SEL_213] (rows=115500 width=1436) Output:["_col0"] - Filter Operator [FIL_202] (rows=115500 width=1436) + Filter Operator [FIL_212] (rows=115500 width=1436) predicate:((i_category = 'Jewelry') and (i_class = 'consignment') and i_item_sk is not null) TableScan [TS_46] (rows=462000 width=1436) default@item,item,Tbl:COMPLETE,Col:NONE,Output:["i_item_sk","i_class","i_category"] @@ -325,55 +325,55 @@ Stage-0 SHUFFLE [RS_55] PartitionCols:_col2 Merge Join Operator [MERGEJOIN_178] (rows=475191764 width=135) - Conds:Union 16._col0=RS_201._col0(Inner),Output:["_col1","_col2"] + Conds:Union 16._col0=RS_211._col0(Inner),Output:["_col1","_col2"] <-Map 22 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_201] + SHUFFLE [RS_211] PartitionCols:_col0 - Select Operator [SEL_200] (rows=18262 width=1119) + Select Operator [SEL_210] (rows=18262 width=1119) Output:["_col0"] - Filter Operator [FIL_199] (rows=18262 width=1119) + Filter Operator [FIL_209] (rows=18262 width=1119) predicate:((d_moy = 3) and (d_year = 1999) and d_date_sk is not null) TableScan [TS_43] (rows=73049 width=1119) default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_year","d_moy"] <-Union 16 [SIMPLE_EDGE] <-Map 15 [CONTAINS] vectorized - Reduce Output Operator [RS_252] + Reduce Output Operator [RS_262] PartitionCols:_col0 - Select Operator [SEL_251] (rows=287989836 width=135) + Select Operator [SEL_261] (rows=287989836 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_250] (rows=287989836 width=135) + Filter Operator [FIL_260] (rows=287989836 width=135) predicate:(cs_bill_customer_sk is not null and cs_item_sk is not null and cs_sold_date_sk is not null) - TableScan [TS_35] (rows=287989836 width=135) + TableScan [TS_187] (rows=287989836 width=135) Output:["cs_sold_date_sk","cs_bill_customer_sk","cs_item_sk"] <-Map 21 [CONTAINS] vectorized - Reduce Output Operator [RS_255] + Reduce Output Operator [RS_265] PartitionCols:_col0 - Select Operator [SEL_254] (rows=144002668 width=135) + Select Operator [SEL_264] (rows=144002668 width=135) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_253] (rows=144002668 width=135) + Filter Operator [FIL_263] (rows=144002668 width=135) predicate:(ws_bill_customer_sk is not null and ws_item_sk is not null and ws_sold_date_sk is not null) - TableScan [TS_38] (rows=144002668 width=135) + TableScan [TS_192] (rows=144002668 width=135) Output:["ws_sold_date_sk","ws_item_sk","ws_bill_customer_sk"] <-Reducer 2 [SIMPLE_EDGE] SHUFFLE [RS_99] PartitionCols:_col1 Merge Join Operator [MERGEJOIN_176] (rows=633595212 width=88) - Conds:RS_189._col0=RS_192._col0(Inner),Output:["_col1","_col2","_col4"] + Conds:RS_199._col0=RS_202._col0(Inner),Output:["_col1","_col2","_col4"] <-Map 1 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_189] + SHUFFLE [RS_199] PartitionCols:_col0 - Select Operator [SEL_188] (rows=575995635 width=88) + Select Operator [SEL_198] (rows=575995635 width=88) Output:["_col0","_col1","_col2"] - Filter Operator [FIL_187] (rows=575995635 width=88) + Filter Operator [FIL_197] (rows=575995635 width=88) predicate:(ss_customer_sk is not null and ss_sold_date_sk is not null) TableScan [TS_23] (rows=575995635 width=88) default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_customer_sk","ss_ext_sales_price"] <-Map 10 [SIMPLE_EDGE] vectorized - SHUFFLE [RS_192] + SHUFFLE [RS_202] PartitionCols:_col0 - Select Operator [SEL_191] (rows=73049 width=1119) + Select Operator [SEL_201] (rows=73049 width=1119) Output:["_col0","_col1"] - Filter Operator [FIL_190] (rows=73049 width=1119) + Filter Operator [FIL_200] (rows=73049 width=1119) predicate:d_date_sk is not null TableScan [TS_26] (rows=73049 width=1119) default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_month_seq"]
