http://git-wip-us.apache.org/repos/asf/hive/blob/f2c4f319/ql/src/test/results/clientpositive/llap/explainuser_2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/explainuser_2.q.out b/ql/src/test/results/clientpositive/llap/explainuser_2.q.out index ea32d34..3675d8d 100644 --- a/ql/src/test/results/clientpositive/llap/explainuser_2.q.out +++ b/ql/src/test/results/clientpositive/llap/explainuser_2.q.out @@ -194,37 +194,37 @@ Stage-0 File Output Operator [FS_16] Select Operator [SEL_15] (rows=63 width=268) Output:["_col0","_col1","_col2"] - Merge Join Operator [MERGEJOIN_26] (rows=63 width=268) - Conds:RS_12._col3=RS_35._col0(Inner),Output:["_col1","_col2","_col4"] + Merge Join Operator [MERGEJOIN_46] (rows=63 width=268) + Conds:RS_12._col3=RS_55._col0(Inner),Output:["_col1","_col2","_col4"] <-Map 5 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_35] + SHUFFLE [RS_55] PartitionCols:_col0 - Select Operator [SEL_34] (rows=500 width=369) + Select Operator [SEL_54] (rows=500 width=369) Output:["_col0"] - Filter Operator [FIL_33] (rows=500 width=91) + Filter Operator [FIL_53] (rows=500 width=91) predicate:value is not null TableScan [TS_6] (rows=500 width=91) default@srcpart,z,Tbl:COMPLETE,Col:COMPLETE,Output:["value"] <-Reducer 2 [SIMPLE_EDGE] llap SHUFFLE [RS_12] PartitionCols:_col3 - Merge Join Operator [MERGEJOIN_25] (rows=39 width=266) - Conds:RS_29._col0=RS_32._col0(Inner),Output:["_col1","_col2","_col3"] + Merge Join Operator [MERGEJOIN_45] (rows=39 width=266) + Conds:RS_49._col0=RS_52._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 1 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_29] + SHUFFLE [RS_49] PartitionCols:_col0 - Select Operator [SEL_28] (rows=500 width=178) + Select Operator [SEL_48] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_27] (rows=500 width=178) + Filter Operator [FIL_47] (rows=500 width=178) predicate:key is not null TableScan [TS_0] (rows=500 width=178) default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"] <-Map 4 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_32] + SHUFFLE [RS_52] PartitionCols:_col0 - Select Operator [SEL_31] (rows=25 width=175) + Select Operator [SEL_51] (rows=25 width=175) Output:["_col0","_col1"] - Filter Operator [FIL_30] (rows=25 width=175) + Filter Operator [FIL_50] (rows=25 width=175) predicate:(key is not null and value is not null) TableScan [TS_3] (rows=25 width=175) default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"] @@ -303,121 +303,121 @@ Stage-0 limit:100 Stage-1 Reducer 5 vectorized, llap - File Output Operator [FS_126] - Limit [LIM_125] (rows=12 width=285) + File Output Operator [FS_216] + Limit [LIM_215] (rows=12 width=285) Number of rows:100 - Select Operator [SEL_124] (rows=12 width=285) + Select Operator [SEL_214] (rows=12 width=285) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] <-Reducer 4 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_123] - Group By Operator [GBY_122] (rows=12 width=285) + SHUFFLE [RS_213] + Group By Operator [GBY_212] (rows=12 width=285) Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["count(VALUE._col0)","count(VALUE._col1)","count(VALUE._col2)"],keys:KEY._col0, KEY._col1, KEY._col2 <-Reducer 3 [SIMPLE_EDGE] llap SHUFFLE [RS_49] PartitionCols:_col0, _col1, _col2 Group By Operator [GBY_48] (rows=12 width=285) Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["count(_col11)","count(_col21)","count(_col3)"],keys:_col10, _col20, _col2 - Merge Join Operator [MERGEJOIN_97] (rows=9275 width=534) + Merge Join Operator [MERGEJOIN_187] (rows=9275 width=534) Conds:RS_44._col1, _col3=RS_45._col15, _col17(Inner),Output:["_col2","_col3","_col10","_col11","_col20","_col21"] <-Reducer 10 [SIMPLE_EDGE] llap SHUFFLE [RS_45] PartitionCols:_col15, _col17 Select Operator [SEL_40] (rows=420 width=447) Output:["_col4","_col5","_col14","_col15","_col17"] - Merge Join Operator [MERGEJOIN_96] (rows=420 width=447) + Merge Join Operator [MERGEJOIN_186] (rows=420 width=447) Conds:RS_37._col4, _col2=RS_38._col4, _col2(Inner),Output:["_col0","_col1","_col14","_col15","_col17"] <-Reducer 11 [SIMPLE_EDGE] llap SHUFFLE [RS_38] PartitionCols:_col4, _col2 - Merge Join Operator [MERGEJOIN_95] (rows=10 width=356) - Conds:RS_121._col0=RS_109._col0(Inner),Output:["_col2","_col3","_col4","_col5"] + Merge Join Operator [MERGEJOIN_185] (rows=10 width=356) + Conds:RS_211._col0=RS_199._col0(Inner),Output:["_col2","_col3","_col4","_col5"] <-Map 6 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_109] + SHUFFLE [RS_199] PartitionCols:_col0 - Select Operator [SEL_106] (rows=25 width=178) + Select Operator [SEL_196] (rows=25 width=178) Output:["_col0"] - Filter Operator [FIL_103] (rows=25 width=178) + Filter Operator [FIL_193] (rows=25 width=178) predicate:((value) IN ('2000Q1', '2000Q2', '2000Q3') and key is not null) TableScan [TS_3] (rows=500 width=178) default@src,d3,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"] <-Map 15 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_121] + SHUFFLE [RS_211] PartitionCols:_col0 - Select Operator [SEL_120] (rows=7 width=531) + Select Operator [SEL_210] (rows=7 width=531) Output:["_col0","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_119] (rows=7 width=534) + Filter Operator [FIL_209] (rows=7 width=534) predicate:((v1 = 'srv1') and k1 is not null and k2 is not null and k3 is not null and v2 is not null and v3 is not null) TableScan [TS_18] (rows=85 width=534) default@sr,sr,Tbl:COMPLETE,Col:COMPLETE,Output:["k1","v1","k2","v2","k3","v3"] <-Reducer 9 [SIMPLE_EDGE] llap SHUFFLE [RS_37] PartitionCols:_col4, _col2 - Merge Join Operator [MERGEJOIN_94] (rows=42 width=352) - Conds:RS_34._col1=RS_118._col1(Inner),Output:["_col0","_col1","_col2","_col4"] + Merge Join Operator [MERGEJOIN_184] (rows=42 width=352) + Conds:RS_34._col1=RS_208._col1(Inner),Output:["_col0","_col1","_col2","_col4"] <-Map 14 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_118] + SHUFFLE [RS_208] PartitionCols:_col1 - Select Operator [SEL_117] (rows=2 width=180) + Select Operator [SEL_207] (rows=2 width=180) Output:["_col1"] - Filter Operator [FIL_116] (rows=2 width=175) + Filter Operator [FIL_206] (rows=2 width=175) predicate:((key = 'src1key') and value is not null) TableScan [TS_15] (rows=25 width=175) default@src1,src1,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"] <-Reducer 8 [SIMPLE_EDGE] llap SHUFFLE [RS_34] PartitionCols:_col1 - Merge Join Operator [MERGEJOIN_93] (rows=42 width=352) - Conds:RS_31._col3=RS_115._col1(Inner),Output:["_col0","_col1","_col2","_col4"] + Merge Join Operator [MERGEJOIN_183] (rows=42 width=352) + Conds:RS_31._col3=RS_205._col1(Inner),Output:["_col0","_col1","_col2","_col4"] <-Map 13 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_115] + SHUFFLE [RS_205] PartitionCols:_col1 - Select Operator [SEL_114] (rows=6 width=185) + Select Operator [SEL_204] (rows=6 width=185) Output:["_col1"] - Filter Operator [FIL_113] (rows=6 width=178) + Filter Operator [FIL_203] (rows=6 width=178) predicate:((key = 'srcpartkey') and value is not null) TableScan [TS_12] (rows=2000 width=178) default@srcpart,srcpart,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"] <-Reducer 7 [SIMPLE_EDGE] llap SHUFFLE [RS_31] PartitionCols:_col3 - Merge Join Operator [MERGEJOIN_92] (rows=7 width=443) - Conds:RS_112._col0=RS_108._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4"] + Merge Join Operator [MERGEJOIN_182] (rows=7 width=443) + Conds:RS_202._col0=RS_198._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4"] <-Map 6 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_108] + SHUFFLE [RS_198] PartitionCols:_col0 - Select Operator [SEL_105] (rows=2 width=178) + Select Operator [SEL_195] (rows=2 width=178) Output:["_col0"] - Filter Operator [FIL_102] (rows=2 width=178) + Filter Operator [FIL_192] (rows=2 width=178) predicate:((value = 'd1value') and key is not null) Please refer to the previous TableScan [TS_3] <-Map 12 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_112] + SHUFFLE [RS_202] PartitionCols:_col0 - Select Operator [SEL_111] (rows=7 width=531) + Select Operator [SEL_201] (rows=7 width=531) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_110] (rows=7 width=534) + Filter Operator [FIL_200] (rows=7 width=534) predicate:((v3 = 'ssv3') and k1 is not null and k2 is not null and k3 is not null and v1 is not null and v2 is not null) TableScan [TS_6] (rows=85 width=534) default@ss_n1,ss_n1,Tbl:COMPLETE,Col:COMPLETE,Output:["k1","v1","k2","v2","k3","v3"] <-Reducer 2 [SIMPLE_EDGE] llap SHUFFLE [RS_44] PartitionCols:_col1, _col3 - Merge Join Operator [MERGEJOIN_91] (rows=265 width=269) - Conds:RS_100._col0=RS_107._col0(Inner),Output:["_col1","_col2","_col3"] + Merge Join Operator [MERGEJOIN_181] (rows=265 width=269) + Conds:RS_190._col0=RS_197._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 6 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_107] + SHUFFLE [RS_197] PartitionCols:_col0 - Select Operator [SEL_104] (rows=25 width=178) + Select Operator [SEL_194] (rows=25 width=178) Output:["_col0"] - Filter Operator [FIL_101] (rows=25 width=178) + Filter Operator [FIL_191] (rows=25 width=178) predicate:((value) IN ('2000Q1', '2000Q2', '2000Q3') and key is not null) Please refer to the previous TableScan [TS_3] <-Map 1 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_100] + SHUFFLE [RS_190] PartitionCols:_col0 - Select Operator [SEL_99] (rows=170 width=356) + Select Operator [SEL_189] (rows=170 width=356) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_98] (rows=170 width=356) + Filter Operator [FIL_188] (rows=170 width=356) predicate:(k1 is not null and v2 is not null and v3 is not null) TableScan [TS_0] (rows=170 width=356) default@cs,cs,Tbl:COMPLETE,Col:COMPLETE,Output:["k1","v2","k3","v3"] @@ -460,124 +460,124 @@ Stage-0 limit:-1 Stage-1 Reducer 5 vectorized, llap - File Output Operator [FS_130] - Group By Operator [GBY_129] (rows=33 width=177) + File Output Operator [FS_172] + Group By Operator [GBY_171] (rows=33 width=177) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 4 [SIMPLE_EDGE] <-Reducer 3 [CONTAINS] llap - Reduce Output Operator [RS_88] + Reduce Output Operator [RS_130] PartitionCols:_col0, _col1 - Group By Operator [GBY_87] (rows=33 width=177) + Group By Operator [GBY_129] (rows=33 width=177) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_85] (rows=33 width=177) + Select Operator [SEL_127] (rows=33 width=177) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_84] (rows=33 width=177) - Conds:RS_22._col2=RS_128._col1(Inner),Output:["_col1","_col4"] + Merge Join Operator [MERGEJOIN_126] (rows=33 width=177) + Conds:RS_22._col2=RS_170._col1(Inner),Output:["_col1","_col4"] <-Reducer 11 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_128] + SHUFFLE [RS_170] PartitionCols:_col1 - Select Operator [SEL_127] (rows=262 width=178) + Select Operator [SEL_169] (rows=262 width=178) Output:["_col1"] - Group By Operator [GBY_126] (rows=262 width=178) + Group By Operator [GBY_168] (rows=262 width=178) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 10 [SIMPLE_EDGE] <-Map 12 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_141] + Reduce Output Operator [RS_183] PartitionCols:_col0, _col1 - Group By Operator [GBY_140] (rows=262 width=178) + Group By Operator [GBY_182] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_139] (rows=500 width=178) + Select Operator [SEL_181] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_138] (rows=500 width=178) + Filter Operator [FIL_180] (rows=500 width=178) predicate:value is not null - TableScan [TS_100] (rows=500 width=178) + TableScan [TS_142] (rows=500 width=178) Output:["key","value"] <-Map 9 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_137] + Reduce Output Operator [RS_179] PartitionCols:_col0, _col1 - Group By Operator [GBY_136] (rows=262 width=178) + Group By Operator [GBY_178] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_135] (rows=25 width=175) + Select Operator [SEL_177] (rows=25 width=175) Output:["_col0","_col1"] - Filter Operator [FIL_134] (rows=25 width=175) + Filter Operator [FIL_176] (rows=25 width=175) predicate:value is not null - TableScan [TS_94] (rows=25 width=175) + TableScan [TS_136] (rows=25 width=175) Output:["key","value"] <-Reducer 2 [SIMPLE_EDGE] llap SHUFFLE [RS_22] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_80] (rows=39 width=175) - Conds:RS_120._col0=RS_124._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_122] (rows=39 width=175) + Conds:RS_162._col0=RS_166._col0(Inner),Output:["_col1","_col2"] <-Map 1 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_120] + SHUFFLE [RS_162] PartitionCols:_col0 - Select Operator [SEL_119] (rows=500 width=87) + Select Operator [SEL_161] (rows=500 width=87) Output:["_col0"] - Filter Operator [FIL_118] (rows=500 width=87) + Filter Operator [FIL_160] (rows=500 width=87) predicate:key is not null TableScan [TS_0] (rows=500 width=87) default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key"] <-Map 8 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_124] + SHUFFLE [RS_166] PartitionCols:_col0 - Select Operator [SEL_123] (rows=25 width=175) + Select Operator [SEL_165] (rows=25 width=175) Output:["_col0","_col1"] - Filter Operator [FIL_122] (rows=25 width=175) + Filter Operator [FIL_164] (rows=25 width=175) predicate:(key is not null and value is not null) TableScan [TS_3] (rows=25 width=175) default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"] <-Reducer 7 [CONTAINS] llap - Reduce Output Operator [RS_93] + Reduce Output Operator [RS_135] PartitionCols:_col0, _col1 - Group By Operator [GBY_92] (rows=33 width=177) + Group By Operator [GBY_134] (rows=33 width=177) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_90] (rows=33 width=177) + Select Operator [SEL_132] (rows=33 width=177) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_89] (rows=33 width=177) - Conds:RS_48._col2=RS_133._col1(Inner),Output:["_col1","_col4"] + Merge Join Operator [MERGEJOIN_131] (rows=33 width=177) + Conds:RS_48._col2=RS_175._col1(Inner),Output:["_col1","_col4"] <-Reducer 15 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_133] + SHUFFLE [RS_175] PartitionCols:_col1 - Select Operator [SEL_132] (rows=262 width=178) + Select Operator [SEL_174] (rows=262 width=178) Output:["_col1"] - Group By Operator [GBY_131] (rows=262 width=178) + Group By Operator [GBY_173] (rows=262 width=178) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 14 [SIMPLE_EDGE] <-Map 13 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_145] + Reduce Output Operator [RS_187] PartitionCols:_col0, _col1 - Group By Operator [GBY_144] (rows=262 width=178) + Group By Operator [GBY_186] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_143] (rows=25 width=175) + Select Operator [SEL_185] (rows=25 width=175) Output:["_col0","_col1"] - Filter Operator [FIL_142] (rows=25 width=175) + Filter Operator [FIL_184] (rows=25 width=175) predicate:value is not null - TableScan [TS_106] (rows=25 width=175) + TableScan [TS_148] (rows=25 width=175) Output:["key","value"] <-Map 16 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_149] + Reduce Output Operator [RS_191] PartitionCols:_col0, _col1 - Group By Operator [GBY_148] (rows=262 width=178) + Group By Operator [GBY_190] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_147] (rows=500 width=178) + Select Operator [SEL_189] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_146] (rows=500 width=178) + Filter Operator [FIL_188] (rows=500 width=178) predicate:value is not null - TableScan [TS_112] (rows=500 width=178) + TableScan [TS_154] (rows=500 width=178) Output:["key","value"] <-Reducer 6 [SIMPLE_EDGE] llap SHUFFLE [RS_48] PartitionCols:_col2 - Merge Join Operator [MERGEJOIN_81] (rows=39 width=175) - Conds:RS_121._col0=RS_125._col0(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_123] (rows=39 width=175) + Conds:RS_163._col0=RS_167._col0(Inner),Output:["_col1","_col2"] <-Map 1 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_121] + SHUFFLE [RS_163] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_119] + Please refer to the previous Select Operator [SEL_161] <-Map 8 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_125] + SHUFFLE [RS_167] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_123] + Please refer to the previous Select Operator [SEL_165] PREHOOK: query: explain SELECT x.key, y.value @@ -636,237 +636,237 @@ Stage-0 limit:-1 Stage-1 Reducer 7 vectorized, llap - File Output Operator [FS_268] - Group By Operator [GBY_267] (rows=47 width=177) + File Output Operator [FS_334] + Group By Operator [GBY_333] (rows=47 width=177) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 6 [SIMPLE_EDGE] <-Reducer 5 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_266] + Reduce Output Operator [RS_332] PartitionCols:_col0, _col1 - Group By Operator [GBY_265] (rows=47 width=177) + Group By Operator [GBY_331] (rows=47 width=177) Output:["_col0","_col1"],keys:_col0, _col1 - Group By Operator [GBY_264] (rows=40 width=177) + Group By Operator [GBY_330] (rows=40 width=177) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 4 [SIMPLE_EDGE] <-Reducer 10 [CONTAINS] llap - Reduce Output Operator [RS_183] + Reduce Output Operator [RS_249] PartitionCols:_col0, _col1 - Group By Operator [GBY_182] (rows=40 width=177) + Group By Operator [GBY_248] (rows=40 width=177) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_180] (rows=48 width=177) + Select Operator [SEL_246] (rows=48 width=177) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_179] (rows=48 width=177) - Conds:RS_58._col3=RS_274._col1(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_245] (rows=48 width=177) + Conds:RS_58._col3=RS_340._col1(Inner),Output:["_col1","_col2"] <-Reducer 20 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_274] + SHUFFLE [RS_340] PartitionCols:_col1 - Select Operator [SEL_273] (rows=381 width=178) + Select Operator [SEL_339] (rows=381 width=178) Output:["_col1"] - Group By Operator [GBY_272] (rows=381 width=178) + Group By Operator [GBY_338] (rows=381 width=178) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 19 [SIMPLE_EDGE] <-Map 22 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_298] + Reduce Output Operator [RS_364] PartitionCols:_col0, _col1 - Group By Operator [GBY_297] (rows=381 width=178) + Group By Operator [GBY_363] (rows=381 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_296] (rows=500 width=178) + Select Operator [SEL_362] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_295] (rows=500 width=178) + Filter Operator [FIL_361] (rows=500 width=178) predicate:value is not null - TableScan [TS_213] (rows=500 width=178) + TableScan [TS_279] (rows=500 width=178) Output:["key","value"] <-Reducer 18 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_290] + Reduce Output Operator [RS_356] PartitionCols:_col0, _col1 - Group By Operator [GBY_289] (rows=381 width=178) + Group By Operator [GBY_355] (rows=381 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_288] (rows=262 width=178) + Select Operator [SEL_354] (rows=262 width=178) Output:["_col0","_col1"] - Group By Operator [GBY_287] (rows=262 width=178) + Group By Operator [GBY_353] (rows=262 width=178) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 17 [SIMPLE_EDGE] <-Map 16 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_286] + Reduce Output Operator [RS_352] PartitionCols:_col0, _col1 - Group By Operator [GBY_285] (rows=262 width=178) + Group By Operator [GBY_351] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_284] (rows=25 width=175) + Select Operator [SEL_350] (rows=25 width=175) Output:["_col0","_col1"] - Filter Operator [FIL_283] (rows=25 width=175) + Filter Operator [FIL_349] (rows=25 width=175) predicate:value is not null - TableScan [TS_196] (rows=25 width=175) + TableScan [TS_262] (rows=25 width=175) Output:["key","value"] <-Map 21 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_294] + Reduce Output Operator [RS_360] PartitionCols:_col0, _col1 - Group By Operator [GBY_293] (rows=262 width=178) + Group By Operator [GBY_359] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_292] (rows=500 width=178) + Select Operator [SEL_358] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_291] (rows=500 width=178) + Filter Operator [FIL_357] (rows=500 width=178) predicate:value is not null - TableScan [TS_207] (rows=500 width=178) + TableScan [TS_273] (rows=500 width=178) Output:["key","value"] <-Reducer 9 [SIMPLE_EDGE] llap SHUFFLE [RS_58] PartitionCols:_col3 - Merge Join Operator [MERGEJOIN_160] (rows=39 width=266) - Conds:RS_256._col0=RS_260._col0(Inner),Output:["_col1","_col2","_col3"] + Merge Join Operator [MERGEJOIN_226] (rows=39 width=266) + Conds:RS_322._col0=RS_326._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 1 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_256] + SHUFFLE [RS_322] PartitionCols:_col0 - Select Operator [SEL_254] (rows=500 width=178) + Select Operator [SEL_320] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_253] (rows=500 width=178) + Filter Operator [FIL_319] (rows=500 width=178) predicate:key is not null TableScan [TS_0] (rows=500 width=178) default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"] <-Map 11 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_260] + SHUFFLE [RS_326] PartitionCols:_col0 - Select Operator [SEL_258] (rows=25 width=175) + Select Operator [SEL_324] (rows=25 width=175) Output:["_col0","_col1"] - Filter Operator [FIL_257] (rows=25 width=175) + Filter Operator [FIL_323] (rows=25 width=175) predicate:(key is not null and value is not null) TableScan [TS_3] (rows=25 width=175) default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"] <-Reducer 3 [CONTAINS] llap - Reduce Output Operator [RS_169] + Reduce Output Operator [RS_235] PartitionCols:_col0, _col1 - Group By Operator [GBY_168] (rows=40 width=177) + Group By Operator [GBY_234] (rows=40 width=177) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_166] (rows=33 width=177) + Select Operator [SEL_232] (rows=33 width=177) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_165] (rows=33 width=177) - Conds:RS_22._col3=RS_263._col1(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_231] (rows=33 width=177) + Conds:RS_22._col3=RS_329._col1(Inner),Output:["_col1","_col2"] <-Reducer 2 [SIMPLE_EDGE] llap SHUFFLE [RS_22] PartitionCols:_col3 - Merge Join Operator [MERGEJOIN_159] (rows=39 width=266) - Conds:RS_255._col0=RS_259._col0(Inner),Output:["_col1","_col2","_col3"] + Merge Join Operator [MERGEJOIN_225] (rows=39 width=266) + Conds:RS_321._col0=RS_325._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 1 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_255] + SHUFFLE [RS_321] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_254] + Please refer to the previous Select Operator [SEL_320] <-Map 11 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_259] + SHUFFLE [RS_325] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_258] + Please refer to the previous Select Operator [SEL_324] <-Reducer 14 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_263] + SHUFFLE [RS_329] PartitionCols:_col1 - Select Operator [SEL_262] (rows=262 width=178) + Select Operator [SEL_328] (rows=262 width=178) Output:["_col1"] - Group By Operator [GBY_261] (rows=262 width=178) + Group By Operator [GBY_327] (rows=262 width=178) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 13 [SIMPLE_EDGE] <-Map 12 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_278] + Reduce Output Operator [RS_344] PartitionCols:_col0, _col1 - Group By Operator [GBY_277] (rows=262 width=178) + Group By Operator [GBY_343] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_276] (rows=25 width=175) + Select Operator [SEL_342] (rows=25 width=175) Output:["_col0","_col1"] - Filter Operator [FIL_275] (rows=25 width=175) + Filter Operator [FIL_341] (rows=25 width=175) predicate:value is not null - TableScan [TS_184] (rows=25 width=175) + TableScan [TS_250] (rows=25 width=175) Output:["key","value"] <-Map 15 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_282] + Reduce Output Operator [RS_348] PartitionCols:_col0, _col1 - Group By Operator [GBY_281] (rows=262 width=178) + Group By Operator [GBY_347] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_280] (rows=500 width=178) + Select Operator [SEL_346] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_279] (rows=500 width=178) + Filter Operator [FIL_345] (rows=500 width=178) predicate:value is not null - TableScan [TS_190] (rows=500 width=178) + TableScan [TS_256] (rows=500 width=178) Output:["key","value"] <-Reducer 8 [CONTAINS] llap - Reduce Output Operator [RS_178] + Reduce Output Operator [RS_244] PartitionCols:_col0, _col1 - Group By Operator [GBY_177] (rows=47 width=177) + Group By Operator [GBY_243] (rows=47 width=177) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_175] (rows=55 width=177) + Select Operator [SEL_241] (rows=55 width=177) Output:["_col0","_col1"] - Merge Join Operator [MERGEJOIN_174] (rows=55 width=177) - Conds:RS_111._col3=RS_271._col1(Inner),Output:["_col1","_col2"] + Merge Join Operator [MERGEJOIN_240] (rows=55 width=177) + Conds:RS_111._col3=RS_337._col1(Inner),Output:["_col1","_col2"] <-Reducer 2 [SIMPLE_EDGE] llap SHUFFLE [RS_111] PartitionCols:_col3 - Please refer to the previous Merge Join Operator [MERGEJOIN_159] + Please refer to the previous Merge Join Operator [MERGEJOIN_225] <-Reducer 29 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_271] + SHUFFLE [RS_337] PartitionCols:_col1 - Select Operator [SEL_270] (rows=440 width=178) + Select Operator [SEL_336] (rows=440 width=178) Output:["_col1"] - Group By Operator [GBY_269] (rows=440 width=178) + Group By Operator [GBY_335] (rows=440 width=178) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 28 [SIMPLE_EDGE] <-Map 32 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_322] + Reduce Output Operator [RS_388] PartitionCols:_col0, _col1 - Group By Operator [GBY_321] (rows=440 width=178) + Group By Operator [GBY_387] (rows=440 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_320] (rows=500 width=178) + Select Operator [SEL_386] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_319] (rows=500 width=178) + Filter Operator [FIL_385] (rows=500 width=178) predicate:value is not null - TableScan [TS_247] (rows=500 width=178) + TableScan [TS_313] (rows=500 width=178) Output:["key","value"] <-Reducer 27 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_310] + Reduce Output Operator [RS_376] PartitionCols:_col0, _col1 - Group By Operator [GBY_309] (rows=440 width=178) + Group By Operator [GBY_375] (rows=440 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_308] (rows=381 width=178) + Select Operator [SEL_374] (rows=381 width=178) Output:["_col0","_col1"] - Group By Operator [GBY_307] (rows=381 width=178) + Group By Operator [GBY_373] (rows=381 width=178) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 26 [SIMPLE_EDGE] <-Map 31 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_318] + Reduce Output Operator [RS_384] PartitionCols:_col0, _col1 - Group By Operator [GBY_317] (rows=381 width=178) + Group By Operator [GBY_383] (rows=381 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_316] (rows=500 width=178) + Select Operator [SEL_382] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_315] (rows=500 width=178) + Filter Operator [FIL_381] (rows=500 width=178) predicate:value is not null - TableScan [TS_241] (rows=500 width=178) + TableScan [TS_307] (rows=500 width=178) Output:["key","value"] <-Reducer 25 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_306] + Reduce Output Operator [RS_372] PartitionCols:_col0, _col1 - Group By Operator [GBY_305] (rows=381 width=178) + Group By Operator [GBY_371] (rows=381 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_304] (rows=262 width=178) + Select Operator [SEL_370] (rows=262 width=178) Output:["_col0","_col1"] - Group By Operator [GBY_303] (rows=262 width=178) + Group By Operator [GBY_369] (rows=262 width=178) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 24 [SIMPLE_EDGE] <-Map 23 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_302] + Reduce Output Operator [RS_368] PartitionCols:_col0, _col1 - Group By Operator [GBY_301] (rows=262 width=178) + Group By Operator [GBY_367] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_300] (rows=25 width=175) + Select Operator [SEL_366] (rows=25 width=175) Output:["_col0","_col1"] - Filter Operator [FIL_299] (rows=25 width=175) + Filter Operator [FIL_365] (rows=25 width=175) predicate:value is not null - TableScan [TS_219] (rows=25 width=175) + TableScan [TS_285] (rows=25 width=175) Output:["key","value"] <-Map 30 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_314] + Reduce Output Operator [RS_380] PartitionCols:_col0, _col1 - Group By Operator [GBY_313] (rows=262 width=178) + Group By Operator [GBY_379] (rows=262 width=178) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_312] (rows=500 width=178) + Select Operator [SEL_378] (rows=500 width=178) Output:["_col0","_col1"] - Filter Operator [FIL_311] (rows=500 width=178) + Filter Operator [FIL_377] (rows=500 width=178) predicate:value is not null - TableScan [TS_235] (rows=500 width=178) + TableScan [TS_301] (rows=500 width=178) Output:["key","value"] PREHOOK: query: EXPLAIN @@ -889,34 +889,34 @@ Stage-0 limit:-1 Stage-1 Map 1 vectorized, llap - File Output Operator [FS_40] - Select Operator [SEL_39] (rows=605 width=10) + File Output Operator [FS_60] + Select Operator [SEL_59] (rows=605 width=10) Output:["_col0","_col1","_col2"] - Map Join Operator [MAPJOIN_38] (rows=605 width=10) - Conds:MAPJOIN_37._col3=RS_34._col0(Inner),Output:["_col1","_col2","_col4"] + Map Join Operator [MAPJOIN_58] (rows=605 width=10) + Conds:MAPJOIN_57._col3=RS_54._col0(Inner),Output:["_col1","_col2","_col4"] <-Map 3 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_34] + BROADCAST [RS_54] PartitionCols:_col0 - Select Operator [SEL_33] (rows=500 width=10) + Select Operator [SEL_53] (rows=500 width=10) Output:["_col0"] - Filter Operator [FIL_32] (rows=500 width=10) + Filter Operator [FIL_52] (rows=500 width=10) predicate:value is not null TableScan [TS_6] (rows=500 width=10) default@srcpart,z,Tbl:COMPLETE,Col:NONE,Output:["value"] - <-Map Join Operator [MAPJOIN_37] (rows=550 width=10) - Conds:SEL_36._col0=RS_31._col0(Inner),Output:["_col1","_col2","_col3"] + <-Map Join Operator [MAPJOIN_57] (rows=550 width=10) + Conds:SEL_56._col0=RS_51._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 2 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_31] + BROADCAST [RS_51] PartitionCols:_col0 - Select Operator [SEL_30] (rows=25 width=7) + Select Operator [SEL_50] (rows=25 width=7) Output:["_col0","_col1"] - Filter Operator [FIL_29] (rows=25 width=7) + Filter Operator [FIL_49] (rows=25 width=7) predicate:(key is not null and value is not null) TableScan [TS_3] (rows=25 width=7) default@src1,x,Tbl:COMPLETE,Col:NONE,Output:["key","value"] - <-Select Operator [SEL_36] (rows=500 width=10) + <-Select Operator [SEL_56] (rows=500 width=10) Output:["_col0","_col1"] - Filter Operator [FIL_35] (rows=500 width=10) + Filter Operator [FIL_55] (rows=500 width=10) predicate:key is not null TableScan [TS_0] (rows=500 width=10) default@src,y,Tbl:COMPLETE,Col:NONE,Output:["key","value"] @@ -992,102 +992,102 @@ Stage-0 limit:100 Stage-1 Reducer 7 vectorized, llap - File Output Operator [FS_142] - Limit [LIM_141] (rows=100 width=10) + File Output Operator [FS_232] + Limit [LIM_231] (rows=100 width=10) Number of rows:100 - Select Operator [SEL_140] (rows=732 width=10) + Select Operator [SEL_230] (rows=732 width=10) Output:["_col0","_col1","_col2","_col3","_col4","_col5"] <-Reducer 6 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_139] - Group By Operator [GBY_138] (rows=732 width=10) + SHUFFLE [RS_229] + Group By Operator [GBY_228] (rows=732 width=10) Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["count(VALUE._col0)","count(VALUE._col1)","count(VALUE._col2)"],keys:KEY._col0, KEY._col1, KEY._col2 <-Map 5 [SIMPLE_EDGE] vectorized, llap - SHUFFLE [RS_137] + SHUFFLE [RS_227] PartitionCols:_col0, _col1, _col2 - Group By Operator [GBY_136] (rows=1464 width=10) + Group By Operator [GBY_226] (rows=1464 width=10) Output:["_col0","_col1","_col2","_col3","_col4","_col5"],aggregations:["count(_col11)","count(_col21)","count(_col3)"],keys:_col10, _col20, _col2 - Map Join Operator [MAPJOIN_135] (rows=1464 width=10) - Conds:RS_118._col1, _col3=SEL_134._col15, _col17(Inner),Output:["_col2","_col3","_col10","_col11","_col20","_col21"] + Map Join Operator [MAPJOIN_225] (rows=1464 width=10) + Conds:RS_208._col1, _col3=SEL_224._col15, _col17(Inner),Output:["_col2","_col3","_col10","_col11","_col20","_col21"] <-Map 2 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_118] + BROADCAST [RS_208] PartitionCols:_col1, _col3 - Map Join Operator [MAPJOIN_117] (rows=275 width=10) - Conds:RS_114._col0=SEL_116._col0(Inner),Output:["_col1","_col2","_col3"] + Map Join Operator [MAPJOIN_207] (rows=275 width=10) + Conds:RS_204._col0=SEL_206._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 1 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_114] + BROADCAST [RS_204] PartitionCols:_col0 - Select Operator [SEL_113] (rows=170 width=34) + Select Operator [SEL_203] (rows=170 width=34) Output:["_col0","_col1","_col2","_col3"] - Filter Operator [FIL_112] (rows=170 width=34) + Filter Operator [FIL_202] (rows=170 width=34) predicate:(k1 is not null and v2 is not null and v3 is not null) TableScan [TS_0] (rows=170 width=34) default@cs,cs,Tbl:COMPLETE,Col:NONE,Output:["k1","v2","k3","v3"] - <-Select Operator [SEL_116] (rows=250 width=10) + <-Select Operator [SEL_206] (rows=250 width=10) Output:["_col0"] - Filter Operator [FIL_115] (rows=250 width=10) + Filter Operator [FIL_205] (rows=250 width=10) predicate:((value) IN ('2000Q1', '2000Q2', '2000Q3') and key is not null) TableScan [TS_3] (rows=500 width=10) default@src,d3,Tbl:COMPLETE,Col:NONE,Output:["key","value"] - <-Select Operator [SEL_134] (rows=1331 width=10) + <-Select Operator [SEL_224] (rows=1331 width=10) Output:["_col4","_col5","_col14","_col15","_col17"] - Map Join Operator [MAPJOIN_133] (rows=1331 width=10) - Conds:MAPJOIN_132._col4, _col2=RS_128._col4, _col2(Inner),Output:["_col0","_col1","_col14","_col15","_col17"] + Map Join Operator [MAPJOIN_223] (rows=1331 width=10) + Conds:MAPJOIN_222._col4, _col2=RS_218._col4, _col2(Inner),Output:["_col0","_col1","_col14","_col15","_col17"] <-Map 10 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_128] + BROADCAST [RS_218] PartitionCols:_col4, _col2 - Map Join Operator [MAPJOIN_127] (rows=275 width=10) - Conds:RS_124._col0=SEL_126._col0(Inner),Output:["_col2","_col3","_col4","_col5"] + Map Join Operator [MAPJOIN_217] (rows=275 width=10) + Conds:RS_214._col0=SEL_216._col0(Inner),Output:["_col2","_col3","_col4","_col5"] <-Map 9 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_124] + BROADCAST [RS_214] PartitionCols:_col0 - Select Operator [SEL_123] (rows=42 width=34) + Select Operator [SEL_213] (rows=42 width=34) Output:["_col0","_col2","_col3","_col4","_col5"] - Filter Operator [FIL_122] (rows=42 width=34) + Filter Operator [FIL_212] (rows=42 width=34) predicate:((v1 = 'srv1') and k1 is not null and k2 is not null and k3 is not null and v2 is not null and v3 is not null) TableScan [TS_18] (rows=85 width=34) default@sr,sr,Tbl:COMPLETE,Col:NONE,Output:["k1","v1","k2","v2","k3","v3"] - <-Select Operator [SEL_126] (rows=250 width=10) + <-Select Operator [SEL_216] (rows=250 width=10) Output:["_col0"] - Filter Operator [FIL_125] (rows=250 width=10) + Filter Operator [FIL_215] (rows=250 width=10) predicate:((value) IN ('2000Q1', '2000Q2', '2000Q3') and key is not null) TableScan [TS_21] (rows=500 width=10) default@src,d2,Tbl:COMPLETE,Col:NONE,Output:["key","value"] - <-Map Join Operator [MAPJOIN_132] (rows=1210 width=10) - Conds:MAPJOIN_131._col1=RS_121._col1(Inner),Output:["_col0","_col1","_col2","_col4"] + <-Map Join Operator [MAPJOIN_222] (rows=1210 width=10) + Conds:MAPJOIN_221._col1=RS_211._col1(Inner),Output:["_col0","_col1","_col2","_col4"] <-Map 8 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_121] + BROADCAST [RS_211] PartitionCols:_col1 - Select Operator [SEL_120] (rows=12 width=7) + Select Operator [SEL_210] (rows=12 width=7) Output:["_col1"] - Filter Operator [FIL_119] (rows=12 width=7) + Filter Operator [FIL_209] (rows=12 width=7) predicate:((key = 'src1key') and value is not null) TableScan [TS_15] (rows=25 width=7) default@src1,src1,Tbl:COMPLETE,Col:NONE,Output:["key","value"] - <-Map Join Operator [MAPJOIN_131] (rows=1100 width=10) - Conds:RS_111._col3=SEL_130._col1(Inner),Output:["_col0","_col1","_col2","_col4"] + <-Map Join Operator [MAPJOIN_221] (rows=1100 width=10) + Conds:RS_201._col3=SEL_220._col1(Inner),Output:["_col0","_col1","_col2","_col4"] <-Map 4 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_111] + BROADCAST [RS_201] PartitionCols:_col3 - Map Join Operator [MAPJOIN_110] (rows=275 width=10) - Conds:RS_107._col0=SEL_109._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4"] + Map Join Operator [MAPJOIN_200] (rows=275 width=10) + Conds:RS_197._col0=SEL_199._col0(Inner),Output:["_col0","_col1","_col2","_col3","_col4"] <-Map 3 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_107] + BROADCAST [RS_197] PartitionCols:_col0 - Select Operator [SEL_106] (rows=42 width=34) + Select Operator [SEL_196] (rows=42 width=34) Output:["_col0","_col1","_col2","_col3","_col4"] - Filter Operator [FIL_105] (rows=42 width=34) + Filter Operator [FIL_195] (rows=42 width=34) predicate:((v3 = 'ssv3') and k1 is not null and k2 is not null and k3 is not null and v1 is not null and v2 is not null) TableScan [TS_6] (rows=85 width=34) default@ss_n1,ss_n1,Tbl:COMPLETE,Col:NONE,Output:["k1","v1","k2","v2","k3","v3"] - <-Select Operator [SEL_109] (rows=250 width=10) + <-Select Operator [SEL_199] (rows=250 width=10) Output:["_col0"] - Filter Operator [FIL_108] (rows=250 width=10) + Filter Operator [FIL_198] (rows=250 width=10) predicate:((value = 'd1value') and key is not null) TableScan [TS_9] (rows=500 width=10) default@src,d1,Tbl:COMPLETE,Col:NONE,Output:["key","value"] - <-Select Operator [SEL_130] (rows=1000 width=10) + <-Select Operator [SEL_220] (rows=1000 width=10) Output:["_col1"] - Filter Operator [FIL_129] (rows=1000 width=10) + Filter Operator [FIL_219] (rows=1000 width=10) predicate:((key = 'srcpartkey') and value is not null) TableScan [TS_12] (rows=2000 width=10) default@srcpart,srcpart,Tbl:COMPLETE,Col:NONE,Output:["key","value"] @@ -1128,116 +1128,116 @@ Stage-0 limit:-1 Stage-1 Reducer 7 vectorized, llap - File Output Operator [FS_147] - Group By Operator [GBY_146] (rows=605 width=10) + File Output Operator [FS_189] + Group By Operator [GBY_188] (rows=605 width=10) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 6 [SIMPLE_EDGE] <-Reducer 12 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_165] + Reduce Output Operator [RS_207] PartitionCols:_col0, _col1 - Group By Operator [GBY_164] (rows=1210 width=10) + Group By Operator [GBY_206] (rows=1210 width=10) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_163] (rows=605 width=10) + Select Operator [SEL_205] (rows=605 width=10) Output:["_col0","_col1"] - Map Join Operator [MAPJOIN_162] (rows=605 width=10) - Conds:RS_159._col2=SEL_161._col1(Inner),Output:["_col1","_col4"] + Map Join Operator [MAPJOIN_204] (rows=605 width=10) + Conds:RS_201._col2=SEL_203._col1(Inner),Output:["_col1","_col4"] <-Map 9 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_159] + BROADCAST [RS_201] PartitionCols:_col2 - Map Join Operator [MAPJOIN_158] (rows=550 width=10) - Conds:SEL_157._col0=RS_135._col0(Inner),Output:["_col1","_col2"] + Map Join Operator [MAPJOIN_200] (rows=550 width=10) + Conds:SEL_199._col0=RS_177._col0(Inner),Output:["_col1","_col2"] <-Map 2 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_135] + BROADCAST [RS_177] PartitionCols:_col0 - Select Operator [SEL_133] (rows=25 width=7) + Select Operator [SEL_175] (rows=25 width=7) Output:["_col0","_col1"] - Filter Operator [FIL_132] (rows=25 width=7) + Filter Operator [FIL_174] (rows=25 width=7) predicate:(key is not null and value is not null) TableScan [TS_3] (rows=25 width=7) default@src1,x,Tbl:COMPLETE,Col:NONE,Output:["key","value"] - <-Select Operator [SEL_157] (rows=500 width=10) + <-Select Operator [SEL_199] (rows=500 width=10) Output:["_col0"] - Filter Operator [FIL_156] (rows=500 width=10) + Filter Operator [FIL_198] (rows=500 width=10) predicate:key is not null TableScan [TS_26] (rows=500 width=10) default@src,y,Tbl:COMPLETE,Col:NONE,Output:["key"] - <-Select Operator [SEL_161] (rows=262 width=10) + <-Select Operator [SEL_203] (rows=262 width=10) Output:["_col1"] - Group By Operator [GBY_160] (rows=262 width=10) + Group By Operator [GBY_202] (rows=262 width=10) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 11 [SIMPLE_EDGE] <-Map 10 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_155] + Reduce Output Operator [RS_197] PartitionCols:_col0, _col1 - Group By Operator [GBY_154] (rows=525 width=10) + Group By Operator [GBY_196] (rows=525 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_153] (rows=25 width=7) + Select Operator [SEL_195] (rows=25 width=7) Output:["_col0","_col1"] - Filter Operator [FIL_152] (rows=25 width=7) + Filter Operator [FIL_194] (rows=25 width=7) predicate:value is not null - TableScan [TS_108] (rows=25 width=7) + TableScan [TS_150] (rows=25 width=7) Output:["key","value"] <-Map 13 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_169] + Reduce Output Operator [RS_211] PartitionCols:_col0, _col1 - Group By Operator [GBY_168] (rows=525 width=10) + Group By Operator [GBY_210] (rows=525 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_167] (rows=500 width=10) + Select Operator [SEL_209] (rows=500 width=10) Output:["_col0","_col1"] - Filter Operator [FIL_166] (rows=500 width=10) + Filter Operator [FIL_208] (rows=500 width=10) predicate:value is not null - TableScan [TS_122] (rows=500 width=10) + TableScan [TS_164] (rows=500 width=10) Output:["key","value"] <-Reducer 5 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_145] + Reduce Output Operator [RS_187] PartitionCols:_col0, _col1 - Group By Operator [GBY_144] (rows=1210 width=10) + Group By Operator [GBY_186] (rows=1210 width=10) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_143] (rows=605 width=10) + Select Operator [SEL_185] (rows=605 width=10) Output:["_col0","_col1"] - Map Join Operator [MAPJOIN_142] (rows=605 width=10) - Conds:RS_139._col2=SEL_141._col1(Inner),Output:["_col1","_col4"] + Map Join Operator [MAPJOIN_184] (rows=605 width=10) + Conds:RS_181._col2=SEL_183._col1(Inner),Output:["_col1","_col4"] <-Map 1 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_139] + BROADCAST [RS_181] PartitionCols:_col2 - Map Join Operator [MAPJOIN_138] (rows=550 width=10) - Conds:SEL_137._col0=RS_134._col0(Inner),Output:["_col1","_col2"] + Map Join Operator [MAPJOIN_180] (rows=550 width=10) + Conds:SEL_179._col0=RS_176._col0(Inner),Output:["_col1","_col2"] <-Map 2 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_134] + BROADCAST [RS_176] PartitionCols:_col0 - Please refer to the previous Select Operator [SEL_133] - <-Select Operator [SEL_137] (rows=500 width=10) + Please refer to the previous Select Operator [SEL_175] + <-Select Operator [SEL_179] (rows=500 width=10) Output:["_col0"] - Filter Operator [FIL_136] (rows=500 width=10) + Filter Operator [FIL_178] (rows=500 width=10) predicate:key is not null TableScan [TS_0] (rows=500 width=10) default@src,y,Tbl:COMPLETE,Col:NONE,Output:["key"] - <-Select Operator [SEL_141] (rows=262 width=10) + <-Select Operator [SEL_183] (rows=262 width=10) Output:["_col1"] - Group By Operator [GBY_140] (rows=262 width=10) + Group By Operator [GBY_182] (rows=262 width=10) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 4 [SIMPLE_EDGE] <-Map 3 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_131] + Reduce Output Operator [RS_173] PartitionCols:_col0, _col1 - Group By Operator [GBY_130] (rows=525 width=10) + Group By Operator [GBY_172] (rows=525 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_129] (rows=25 width=7) + Select Operator [SEL_171] (rows=25 width=7) Output:["_col0","_col1"] - Filter Operator [FIL_128] (rows=25 width=7) + Filter Operator [FIL_170] (rows=25 width=7) predicate:value is not null - TableScan [TS_88] (rows=25 width=7) + TableScan [TS_130] (rows=25 width=7) Output:["key","value"] <-Map 8 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_151] + Reduce Output Operator [RS_193] PartitionCols:_col0, _col1 - Group By Operator [GBY_150] (rows=525 width=10) + Group By Operator [GBY_192] (rows=525 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_149] (rows=500 width=10) + Select Operator [SEL_191] (rows=500 width=10) Output:["_col0","_col1"] - Filter Operator [FIL_148] (rows=500 width=10) + Filter Operator [FIL_190] (rows=500 width=10) predicate:value is not null - TableScan [TS_102] (rows=500 width=10) + TableScan [TS_144] (rows=500 width=10) Output:["key","value"] PREHOOK: query: explain @@ -1294,227 +1294,227 @@ Stage-0 limit:-1 Stage-1 Reducer 9 vectorized, llap - File Output Operator [FS_290] - Group By Operator [GBY_289] (rows=605 width=10) + File Output Operator [FS_356] + Group By Operator [GBY_355] (rows=605 width=10) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 8 [SIMPLE_EDGE] <-Reducer 25 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_338] + Reduce Output Operator [RS_404] PartitionCols:_col0, _col1 - Group By Operator [GBY_337] (rows=1210 width=10) + Group By Operator [GBY_403] (rows=1210 width=10) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_336] (rows=605 width=10) + Select Operator [SEL_402] (rows=605 width=10) Output:["_col0","_col1"] - Map Join Operator [MAPJOIN_335] (rows=605 width=10) - Conds:RS_279._col3=SEL_334._col1(Inner),Output:["_col1","_col2"] + Map Join Operator [MAPJOIN_401] (rows=605 width=10) + Conds:RS_345._col3=SEL_400._col1(Inner),Output:["_col1","_col2"] <-Map 1 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_279] + BROADCAST [RS_345] PartitionCols:_col3 - Map Join Operator [MAPJOIN_277] (rows=550 width=10) - Conds:SEL_276._col0=RS_273._col0(Inner),Output:["_col1","_col2","_col3"] + Map Join Operator [MAPJOIN_343] (rows=550 width=10) + Conds:SEL_342._col0=RS_339._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 2 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_273] + BROADCAST [RS_339] PartitionCols:_col0 - Select Operator [SEL_272] (rows=25 width=7) + Select Operator [SEL_338] (rows=25 width=7) Output:["_col0","_col1"] - Filter Operator [FIL_271] (rows=25 width=7) + Filter Operator [FIL_337] (rows=25 width=7) predicate:(key is not null and value is not null) TableScan [TS_3] (rows=25 width=7) default@src1,x,Tbl:COMPLETE,Col:NONE,Output:["key","value"] - <-Select Operator [SEL_276] (rows=500 width=10) + <-Select Operator [SEL_342] (rows=500 width=10) Output:["_col0","_col1"] - Filter Operator [FIL_275] (rows=500 width=10) + Filter Operator [FIL_341] (rows=500 width=10) predicate:key is not null TableScan [TS_0] (rows=500 width=10) default@src,y,Tbl:COMPLETE,Col:NONE,Output:["key","value"] - <-Select Operator [SEL_334] (rows=440 width=10) + <-Select Operator [SEL_400] (rows=440 width=10) Output:["_col1"] - Group By Operator [GBY_333] (rows=440 width=10) + Group By Operator [GBY_399] (rows=440 width=10) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 24 [SIMPLE_EDGE] <-Map 28 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_350] + Reduce Output Operator [RS_416] PartitionCols:_col0, _col1 - Group By Operator [GBY_349] (rows=881 width=10) + Group By Operator [GBY_415] (rows=881 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_348] (rows=500 width=10) + Select Operator [SEL_414] (rows=500 width=10) Output:["_col0","_col1"] - Filter Operator [FIL_347] (rows=500 width=10) + Filter Operator [FIL_413] (rows=500 width=10) predicate:value is not null - TableScan [TS_261] (rows=500 width=10) + TableScan [TS_327] (rows=500 width=10) Output:["key","value"] <-Reducer 23 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_332] + Reduce Output Operator [RS_398] PartitionCols:_col0, _col1 - Group By Operator [GBY_331] (rows=881 width=10) + Group By Operator [GBY_397] (rows=881 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_330] (rows=381 width=10) + Select Operator [SEL_396] (rows=381 width=10) Output:["_col0","_col1"] - Group By Operator [GBY_329] (rows=381 width=10) + Group By Operator [GBY_395] (rows=381 width=10) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 22 [SIMPLE_EDGE] <-Map 27 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_346] + Reduce Output Operator [RS_412] PartitionCols:_col0, _col1 - Group By Operator [GBY_345] (rows=762 width=10) + Group By Operator [GBY_411] (rows=762 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_344] (rows=500 width=10) + Select Operator [SEL_410] (rows=500 width=10) Output:["_col0","_col1"] - Filter Operator [FIL_343] (rows=500 width=10) + Filter Operator [FIL_409] (rows=500 width=10) predicate:value is not null - TableScan [TS_255] (rows=500 width=10) + TableScan [TS_321] (rows=500 width=10) Output:["key","value"] <-Reducer 21 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_328] + Reduce Output Operator [RS_394] PartitionCols:_col0, _col1 - Group By Operator [GBY_327] (rows=762 width=10) + Group By Operator [GBY_393] (rows=762 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_326] (rows=262 width=10) + Select Operator [SEL_392] (rows=262 width=10) Output:["_col0","_col1"] - Group By Operator [GBY_325] (rows=262 width=10) + Group By Operator [GBY_391] (rows=262 width=10) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 20 [SIMPLE_EDGE] <-Map 19 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_324] + Reduce Output Operator [RS_390] PartitionCols:_col0, _col1 - Group By Operator [GBY_323] (rows=525 width=10) + Group By Operator [GBY_389] (rows=525 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_322] (rows=25 width=7) + Select Operator [SEL_388] (rows=25 width=7) Output:["_col0","_col1"] - Filter Operator [FIL_321] (rows=25 width=7) + Filter Operator [FIL_387] (rows=25 width=7) predicate:value is not null - TableScan [TS_225] (rows=25 width=7) + TableScan [TS_291] (rows=25 width=7) Output:["key","value"] <-Map 26 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_342] + Reduce Output Operator [RS_408] PartitionCols:_col0, _col1 - Group By Operator [GBY_341] (rows=525 width=10) + Group By Operator [GBY_407] (rows=525 width=10) Output:["_col0","_col1"],keys:_col1, _col0 - Select Operator [SEL_340] (rows=500 width=10) + Select Operator [SEL_406] (rows=500 width=10) Output:["_col0","_col1"] - Filter Operator [FIL_339] (rows=500 width=10) + Filter Operator [FIL_405] (rows=500 width=10) predicate:value is not null - TableScan [TS_249] (rows=500 width=10) + TableScan [TS_315] (rows=500 width=10) Output:["key","value"] <-Reducer 7 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_288] + Reduce Output Operator [RS_354] PartitionCols:_col0, _col1 - Group By Operator [GBY_287] (rows=1210 width=10) + Group By Operator [GBY_353] (rows=1210 width=10) Output:["_col0","_col1"],keys:_col0, _col1 - Group By Operator [GBY_286] (rows=605 width=10) + Group By Operator [GBY_352] (rows=605 width=10) Output:["_col0","_col1"],keys:KEY._col0, KEY._col1 <-Union 6 [SIMPLE_EDGE] <-Reducer 16 [CONTAINS] vectorized, llap - Reduce Output Operator [RS_312] + Reduce Output Operator [RS_378] PartitionCols:_col0, _col1 - Group By Operator [GBY_311] (rows=1210 width=10) + Group By Operator [GBY_377] (rows=1210 width=10) Output:["_col0","_col1"],keys:_col0, _col1 - Select Operator [SEL_310] (rows=605 width=10) + Select Operator [SEL_376] (rows=605 width=10) Output:["_col0","_col1"] - Map Join Operator [MAPJOIN_309] (rows=605 width=10) - Conds:RS_306._col3=SEL_308._col1(Inner),Output:["_col1","_col2"] + Map Join Operator [MAPJOIN_375] (rows=605 width=10) + Conds:RS_372._col3=SEL_374._col1(Inner),Output:["_col1","_col2"] <-Map 11 [BROADCAST_EDGE] vectorized, llap - BROADCAST [RS_306] + BROADCAST [RS_372] PartitionCols:_col3 - Map Join Operator [MAPJOIN_305] (rows=550 width=10) - Conds:SEL_304._col0=RS_274._col0(Inner),Output:["_col1","_col2","_col3"] + Map Join Operator [MAPJOIN_371] (rows=550 width=10) + Conds:SEL_370._col0=RS_340._col0(Inner),Output:["_col1","_col2","_col3"] <-Map 2 [BROAD
<TRUNCATED>
