Return-Path: X-Original-To: apmail-hive-commits-archive@www.apache.org Delivered-To: apmail-hive-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 64487CF6F for ; Thu, 11 Dec 2014 17:34:10 +0000 (UTC) Received: (qmail 22682 invoked by uid 500); 11 Dec 2014 17:34:10 -0000 Delivered-To: apmail-hive-commits-archive@hive.apache.org Received: (qmail 22638 invoked by uid 500); 11 Dec 2014 17:34:10 -0000 Mailing-List: contact commits-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hive-dev@hive.apache.org Delivered-To: mailing list commits@hive.apache.org Received: (qmail 22626 invoked by uid 99); 11 Dec 2014 17:34:10 -0000 Received: from eris.apache.org (HELO hades.apache.org) (140.211.11.105) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 11 Dec 2014 17:34:10 +0000 Received: from hades.apache.org (localhost [127.0.0.1]) by hades.apache.org (ASF Mail Server at hades.apache.org) with ESMTP id 843B6AC094D; Thu, 11 Dec 2014 17:34:08 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1644709 [1/2] - in /hive/trunk/ql/src: java/org/apache/hadoop/hive/ql/optimizer/ java/org/apache/hadoop/hive/ql/plan/ test/results/clientpositive/tez/ Date: Thu, 11 Dec 2014 17:34:07 -0000 To: commits@hive.apache.org From: hashutosh@apache.org X-Mailer: svnmailer-1.0.9 Message-Id: <20141211173409.843B6AC094D@hades.apache.org> Author: hashutosh Date: Thu Dec 11 17:34:07 2014 New Revision: 1644709 URL: http://svn.apache.org/r1644709 Log: HIVE-9062 : Explain plan doesn't print join keys for Tez shuffle join (Ashutosh Chauhan via Vikram Dixit) Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/MapJoinProcessor.java hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/CommonMergeJoinDesc.java hive/trunk/ql/src/test/results/clientpositive/tez/auto_sortmerge_join_6.q.out hive/trunk/ql/src/test/results/clientpositive/tez/correlationoptimizer1.q.out hive/trunk/ql/src/test/results/clientpositive/tez/cross_join.q.out hive/trunk/ql/src/test/results/clientpositive/tez/cross_product_check_1.q.out hive/trunk/ql/src/test/results/clientpositive/tez/dynamic_partition_pruning.q.out hive/trunk/ql/src/test/results/clientpositive/tez/filter_join_breaktask.q.out hive/trunk/ql/src/test/results/clientpositive/tez/join0.q.out hive/trunk/ql/src/test/results/clientpositive/tez/join1.q.out hive/trunk/ql/src/test/results/clientpositive/tez/join_nullsafe.q.out hive/trunk/ql/src/test/results/clientpositive/tez/limit_pushdown.q.out hive/trunk/ql/src/test/results/clientpositive/tez/metadataonly1.q.out hive/trunk/ql/src/test/results/clientpositive/tez/mrr.q.out hive/trunk/ql/src/test/results/clientpositive/tez/optimize_nullscan.q.out hive/trunk/ql/src/test/results/clientpositive/tez/skewjoin.q.out hive/trunk/ql/src/test/results/clientpositive/tez/subquery_exists.q.out hive/trunk/ql/src/test/results/clientpositive/tez/subquery_in.q.out hive/trunk/ql/src/test/results/clientpositive/tez/tez_join_hash.q.out hive/trunk/ql/src/test/results/clientpositive/tez/tez_join_tests.q.out hive/trunk/ql/src/test/results/clientpositive/tez/tez_joins_explain.q.out hive/trunk/ql/src/test/results/clientpositive/tez/tez_smb_main.q.out hive/trunk/ql/src/test/results/clientpositive/tez/tez_union.q.out hive/trunk/ql/src/test/results/clientpositive/tez/tez_union_group_by.q.out hive/trunk/ql/src/test/results/clientpositive/tez/vectorized_bucketmapjoin1.q.out hive/trunk/ql/src/test/results/clientpositive/tez/vectorized_dynamic_partition_pruning.q.out hive/trunk/ql/src/test/results/clientpositive/tez/vectorized_ptf.q.out hive/trunk/ql/src/test/results/clientpositive/tez/vectorized_shufflejoin.q.out Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java (original) +++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java Thu Dec 11 17:34:07 2014 @@ -237,7 +237,8 @@ public class ConvertJoinMapJoin implemen JoinDesc joinDesc = joinOp.getConf(); // retain the original join desc in the map join. mapJoinDesc = - new MapJoinDesc(null, null, joinDesc.getExprs(), null, null, + new MapJoinDesc(MapJoinProcessor.getKeys(parseContext.getJoinContext().get(joinOp), joinOp).getSecond(), + null, joinDesc.getExprs(), null, null, joinDesc.getOutputColumnNames(), mapJoinConversionPos, joinDesc.getConds(), joinDesc.getFilters(), joinDesc.getNoOuterJoin(), null); mapJoinDesc.setNullSafes(joinDesc.getNullSafes()); Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/MapJoinProcessor.java URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/MapJoinProcessor.java?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/MapJoinProcessor.java (original) +++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/MapJoinProcessor.java Thu Dec 11 17:34:07 2014 @@ -32,6 +32,7 @@ import java.util.Stack; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.fs.Path; +import org.apache.hadoop.hive.common.ObjectPair; import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.ql.ErrorMsg; import org.apache.hadoop.hive.ql.exec.AbstractMapJoinOperator; @@ -312,7 +313,6 @@ public class MapJoinProcessor implements // outer join cannot be performed on a table which is being cached JoinDesc desc = op.getConf(); JoinCondDesc[] condns = desc.getConds(); - Byte[] tagOrder = desc.getTagOrder(); if (!noCheckOuterJoin) { if (checkMapJoin(mapJoinPos, condns) < 0) { @@ -320,9 +320,6 @@ public class MapJoinProcessor implements } } - RowResolver outputRS = opParseCtxMap.get(op).getRowResolver(); - Map> keyExprMap = new HashMap>(); - // Walk over all the sources (which are guaranteed to be reduce sink // operators). // The join outputs a concatenation of all the inputs. @@ -1029,19 +1026,7 @@ public class MapJoinProcessor implements } - public static MapJoinDesc getMapJoinDesc(HiveConf hconf, - LinkedHashMap, OpParseContext> opParseCtxMap, - JoinOperator op, QBJoinTree joinTree, int mapJoinPos, boolean noCheckOuterJoin) throws SemanticException { - JoinDesc desc = op.getConf(); - JoinCondDesc[] condns = desc.getConds(); - Byte[] tagOrder = desc.getTagOrder(); - - // outer join cannot be performed on a table which is being cached - if (!noCheckOuterJoin) { - if (checkMapJoin(mapJoinPos, condns) < 0) { - throw new SemanticException(ErrorMsg.NO_OUTER_MAPJOIN.getMsg()); - } - } + public static ObjectPair, Map>> getKeys(QBJoinTree joinTree, JoinOperator op) { // Walk over all the sources (which are guaranteed to be reduce sink // operators). @@ -1066,10 +1051,39 @@ public class MapJoinProcessor implements pos++; } + // get the join keys from old parent ReduceSink operators + Map> keyExprMap = new HashMap>(); + + for (pos = 0; pos < op.getParentOperators().size(); pos++) { + ReduceSinkOperator inputRS = oldReduceSinkParentOps.get(pos); + List keyCols = inputRS.getConf().getKeyCols(); + keyExprMap.put(pos, keyCols); + } + + return new ObjectPair, Map>>(oldReduceSinkParentOps, keyExprMap); + } + + public static MapJoinDesc getMapJoinDesc(HiveConf hconf, + LinkedHashMap, OpParseContext> opParseCtxMap, + JoinOperator op, QBJoinTree joinTree, int mapJoinPos, boolean noCheckOuterJoin) throws SemanticException { + JoinDesc desc = op.getConf(); + JoinCondDesc[] condns = desc.getConds(); + Byte[] tagOrder = desc.getTagOrder(); + + // outer join cannot be performed on a table which is being cached + if (!noCheckOuterJoin) { + if (checkMapJoin(mapJoinPos, condns) < 0) { + throw new SemanticException(ErrorMsg.NO_OUTER_MAPJOIN.getMsg()); + } + } + Map colExprMap = op.getColumnExprMap(); List schema = new ArrayList(op.getSchema().getSignature()); Map> valueExprs = op.getConf().getExprs(); Map> newValueExprs = new HashMap>(); + + ObjectPair, Map>> pair = getKeys(joinTree, op); + List oldReduceSinkParentOps = pair.getFirst(); for (Map.Entry> entry : valueExprs.entrySet()) { byte tag = entry.getKey(); Operator terminal = oldReduceSinkParentOps.get(tag); @@ -1095,15 +1109,13 @@ public class MapJoinProcessor implements Map valueIndices = new HashMap(); // get the join keys from old parent ReduceSink operators - Map> keyExprMap = new HashMap>(); + Map> keyExprMap = pair.getSecond(); // construct valueTableDescs and valueFilteredTableDescs List valueTableDescs = new ArrayList(); List valueFilteredTableDescs = new ArrayList(); int[][] filterMap = desc.getFilterMap(); - for (pos = 0; pos < op.getParentOperators().size(); pos++) { - ReduceSinkOperator inputRS = oldReduceSinkParentOps.get(pos); - List keyCols = inputRS.getConf().getKeyCols(); + for (byte pos = 0; pos < op.getParentOperators().size(); pos++) { List valueCols = newValueExprs.get(pos); if (pos != mapJoinPos) { // remove values in key exprs for value table schema @@ -1113,7 +1125,7 @@ public class MapJoinProcessor implements List valueColsInValueExpr = new ArrayList(); for (int i = 0; i < valueIndex.length; i++) { ExprNodeDesc expr = valueCols.get(i); - int kindex = ExprNodeDescUtils.indexOf(expr, keyCols); + int kindex = ExprNodeDescUtils.indexOf(expr, keyExprMap.get(pos)); if (kindex >= 0) { valueIndex[i] = kindex; } else { @@ -1145,8 +1157,6 @@ public class MapJoinProcessor implements valueTableDescs.add(valueTableDesc); valueFilteredTableDescs.add(valueFilteredTableDesc); - - keyExprMap.put(pos, keyCols); } Map> filters = desc.getFilters(); Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/CommonMergeJoinDesc.java URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/CommonMergeJoinDesc.java?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/CommonMergeJoinDesc.java (original) +++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/CommonMergeJoinDesc.java Thu Dec 11 17:34:07 2014 @@ -19,9 +19,7 @@ package org.apache.hadoop.hive.ql.plan; import java.io.Serializable; -import java.util.Map; -import org.apache.hadoop.hive.ql.exec.Operator; @Explain(displayName = "Merge Join Operator") public class CommonMergeJoinDesc extends MapJoinDesc implements Serializable { Modified: hive/trunk/ql/src/test/results/clientpositive/tez/auto_sortmerge_join_6.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/auto_sortmerge_join_6.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/auto_sortmerge_join_6.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/auto_sortmerge_join_6.q.out Thu Dec 11 17:34:07 2014 @@ -96,24 +96,11 @@ STAGE PLANS: Stage: Stage-1 Tez Edges: - Reducer 3 <- Map 2 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) - Reducer 4 <- Reducer 3 (SIMPLE_EDGE) + Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) + Reducer 3 <- Reducer 2 (SIMPLE_EDGE) #### A masked pattern was here #### Vertices: - Map 2 - Map Operator Tree: - TableScan - alias: c - Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - Filter Operator - predicate: value is not null (type: boolean) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - key expressions: value (type: string) - sort order: + - Map-reduce partition columns: value (type: string) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Map 5 + Map 1 Map Operator Tree: TableScan alias: b @@ -144,7 +131,20 @@ STAGE PLANS: sort order: + Map-reduce partition columns: _col1 (type: string) Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE - Reducer 3 + Map 5 + Map Operator Tree: + TableScan + alias: c + Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE + Filter Operator + predicate: value is not null (type: boolean) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + key expressions: value (type: string) + sort order: + + Map-reduce partition columns: value (type: string) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reducer 2 Reduce Operator Tree: Merge Join Operator condition map: @@ -152,19 +152,20 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 _col1 (type: string) + 1 value (type: string) Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) - Reducer 4 + value expressions: _col0 (type: bigint) + Reducer 3 Reduce Operator Tree: Group By Operator aggregations: count(VALUE._col0) @@ -227,19 +228,6 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: d - Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - Filter Operator - predicate: value is not null (type: boolean) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - key expressions: value (type: string) - sort order: + - Map-reduce partition columns: value (type: string) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Map 5 - Map Operator Tree: - TableScan alias: b Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Filter Operator @@ -268,6 +256,19 @@ STAGE PLANS: sort order: + Map-reduce partition columns: _col1 (type: string) Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE + Map 5 + Map Operator Tree: + TableScan + alias: d + Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE + Filter Operator + predicate: value is not null (type: boolean) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + key expressions: value (type: string) + sort order: + + Map-reduce partition columns: value (type: string) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE Reducer 2 Reduce Operator Tree: Merge Join Operator @@ -276,18 +277,19 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 _col1 (type: string) + 1 value (type: string) Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) + value expressions: _col0 (type: bigint) Reducer 3 Reduce Operator Tree: Group By Operator @@ -344,11 +346,11 @@ STAGE PLANS: Stage: Stage-1 Tez Edges: - Reducer 3 <- Map 2 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) - Reducer 4 <- Reducer 3 (SIMPLE_EDGE) + Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) + Reducer 3 <- Reducer 2 (SIMPLE_EDGE) #### A masked pattern was here #### Vertices: - Map 2 + Map 1 Map Operator Tree: TableScan alias: b @@ -392,7 +394,7 @@ STAGE PLANS: sort order: + Map-reduce partition columns: value (type: string) Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Reducer 3 + Reducer 2 Reduce Operator Tree: Merge Join Operator condition map: @@ -400,19 +402,20 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 _col1 (type: string) + 1 value (type: string) Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) - Reducer 4 + value expressions: _col0 (type: bigint) + Reducer 3 Reduce Operator Tree: Group By Operator aggregations: count(VALUE._col0) @@ -471,7 +474,7 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: b + alias: a Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: UDFToDouble(key) is not null (type: boolean) @@ -484,7 +487,7 @@ STAGE PLANS: Map 4 Map Operator Tree: TableScan - alias: c + alias: b Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: UDFToDouble(key) is not null (type: boolean) @@ -497,7 +500,7 @@ STAGE PLANS: Map 5 Map Operator Tree: TableScan - alias: a + alias: c Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: UDFToDouble(key) is not null (type: boolean) @@ -517,18 +520,20 @@ STAGE PLANS: 0 1 2 + keys: + 0 UDFToDouble(key) (type: double) + 1 UDFToDouble(key) (type: double) + 2 UDFToDouble(key) (type: double) Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) + value expressions: _col0 (type: bigint) Reducer 3 Reduce Operator Tree: Group By Operator @@ -581,10 +586,10 @@ STAGE PLANS: Stage: Stage-1 Tez Edges: - Reducer 4 <- Map 3 (SIMPLE_EDGE) + Reducer 2 <- Map 1 (SIMPLE_EDGE) #### A masked pattern was here #### Vertices: - Map 3 + Map 1 Map Operator Tree: TableScan alias: b @@ -619,18 +624,16 @@ STAGE PLANS: 1 key (type: int) 2 key (type: int) Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) - Reducer 4 + value expressions: _col0 (type: bigint) + Reducer 2 Reduce Operator Tree: Group By Operator aggregations: count(VALUE._col0) @@ -682,24 +685,11 @@ STAGE PLANS: Stage: Stage-1 Tez Edges: - Reducer 3 <- Map 2 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) - Reducer 4 <- Reducer 3 (SIMPLE_EDGE) + Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) + Reducer 3 <- Reducer 2 (SIMPLE_EDGE) #### A masked pattern was here #### Vertices: - Map 2 - Map Operator Tree: - TableScan - alias: c - Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - Filter Operator - predicate: value is not null (type: boolean) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - key expressions: value (type: string) - sort order: + - Map-reduce partition columns: value (type: string) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Map 5 + Map 1 Map Operator Tree: TableScan alias: b @@ -730,7 +720,20 @@ STAGE PLANS: sort order: + Map-reduce partition columns: _col1 (type: string) Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE - Reducer 3 + Map 5 + Map Operator Tree: + TableScan + alias: c + Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE + Filter Operator + predicate: value is not null (type: boolean) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + key expressions: value (type: string) + sort order: + + Map-reduce partition columns: value (type: string) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reducer 2 Reduce Operator Tree: Merge Join Operator condition map: @@ -738,19 +741,20 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 _col1 (type: string) + 1 value (type: string) Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) - Reducer 4 + value expressions: _col0 (type: bigint) + Reducer 3 Reduce Operator Tree: Group By Operator aggregations: count(VALUE._col0) @@ -802,24 +806,11 @@ STAGE PLANS: Stage: Stage-1 Tez Edges: - Reducer 3 <- Map 2 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) - Reducer 4 <- Reducer 3 (SIMPLE_EDGE) + Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) + Reducer 3 <- Reducer 2 (SIMPLE_EDGE) #### A masked pattern was here #### Vertices: - Map 2 - Map Operator Tree: - TableScan - alias: c - Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - Filter Operator - predicate: value is not null (type: boolean) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - key expressions: value (type: string) - sort order: + - Map-reduce partition columns: value (type: string) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Map 5 + Map 1 Map Operator Tree: TableScan alias: b @@ -850,7 +841,20 @@ STAGE PLANS: sort order: + Map-reduce partition columns: _col1 (type: string) Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE - Reducer 3 + Map 5 + Map Operator Tree: + TableScan + alias: c + Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE + Filter Operator + predicate: value is not null (type: boolean) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + key expressions: value (type: string) + sort order: + + Map-reduce partition columns: value (type: string) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reducer 2 Reduce Operator Tree: Merge Join Operator condition map: @@ -858,19 +862,20 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 _col1 (type: string) + 1 value (type: string) Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) - Reducer 4 + value expressions: _col0 (type: bigint) + Reducer 3 Reduce Operator Tree: Group By Operator aggregations: count(VALUE._col0) @@ -929,7 +934,7 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: b + alias: a Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: UDFToDouble(key) is not null (type: boolean) @@ -942,7 +947,7 @@ STAGE PLANS: Map 4 Map Operator Tree: TableScan - alias: c + alias: b Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: UDFToDouble(key) is not null (type: boolean) @@ -955,7 +960,7 @@ STAGE PLANS: Map 5 Map Operator Tree: TableScan - alias: a + alias: c Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: UDFToDouble(key) is not null (type: boolean) @@ -975,18 +980,20 @@ STAGE PLANS: 0 1 2 + keys: + 0 UDFToDouble(key) (type: double) + 1 UDFToDouble(key) (type: double) + 2 UDFToDouble(key) (type: double) Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) + value expressions: _col0 (type: bigint) Reducer 3 Reduce Operator Tree: Group By Operator @@ -1039,10 +1046,10 @@ STAGE PLANS: Stage: Stage-1 Tez Edges: - Reducer 4 <- Map 3 (SIMPLE_EDGE) + Reducer 2 <- Map 1 (SIMPLE_EDGE) #### A masked pattern was here #### Vertices: - Map 3 + Map 1 Map Operator Tree: TableScan alias: b @@ -1077,18 +1084,16 @@ STAGE PLANS: 1 key (type: int) 2 key (type: int) Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) - Reducer 4 + value expressions: _col0 (type: bigint) + Reducer 2 Reduce Operator Tree: Group By Operator aggregations: count(VALUE._col0) @@ -1140,24 +1145,11 @@ STAGE PLANS: Stage: Stage-1 Tez Edges: - Reducer 3 <- Map 2 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) - Reducer 4 <- Reducer 3 (SIMPLE_EDGE) + Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 5 (SIMPLE_EDGE) + Reducer 3 <- Reducer 2 (SIMPLE_EDGE) #### A masked pattern was here #### Vertices: - Map 2 - Map Operator Tree: - TableScan - alias: c - Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - Filter Operator - predicate: value is not null (type: boolean) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - key expressions: value (type: string) - sort order: + - Map-reduce partition columns: value (type: string) - Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE - Map 5 + Map 1 Map Operator Tree: TableScan alias: b @@ -1188,7 +1180,20 @@ STAGE PLANS: sort order: + Map-reduce partition columns: _col1 (type: string) Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE - Reducer 3 + Map 5 + Map Operator Tree: + TableScan + alias: c + Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE + Filter Operator + predicate: value is not null (type: boolean) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + key expressions: value (type: string) + sort order: + + Map-reduce partition columns: value (type: string) + Statistics: Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE + Reducer 2 Reduce Operator Tree: Merge Join Operator condition map: @@ -1196,19 +1201,20 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 _col1 (type: string) + 1 value (type: string) Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Select Operator - Statistics: Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE - Group By Operator - aggregations: count() - mode: hash - outputColumnNames: _col0 + Group By Operator + aggregations: count() + mode: hash + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE + Reduce Output Operator + sort order: Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - Reduce Output Operator - sort order: - Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE - value expressions: _col0 (type: bigint) - Reducer 4 + value expressions: _col0 (type: bigint) + Reducer 3 Reduce Operator Tree: Group By Operator aggregations: count(VALUE._col0) Modified: hive/trunk/ql/src/test/results/clientpositive/tez/correlationoptimizer1.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/correlationoptimizer1.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/correlationoptimizer1.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/correlationoptimizer1.q.out Thu Dec 11 17:34:07 2014 @@ -67,6 +67,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -199,6 +202,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -484,6 +490,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 _col0 (type: string) outputColumnNames: _col0 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -625,6 +634,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 _col0 (type: string) outputColumnNames: _col0 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -757,6 +769,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -883,6 +898,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1015,6 +1033,9 @@ STAGE PLANS: condition expressions: 0 1 {KEY.reducesinkkey0} + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col5 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1141,6 +1162,9 @@ STAGE PLANS: condition expressions: 0 1 {KEY.reducesinkkey0} + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col5 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1270,6 +1294,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 {KEY.reducesinkkey1} + keys: + 0 key (type: string), value (type: string) + 1 key (type: string), value (type: string) outputColumnNames: _col0, _col6 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1390,6 +1417,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 {KEY.reducesinkkey1} + keys: + 0 key (type: string), value (type: string) + 1 key (type: string), value (type: string) outputColumnNames: _col0, _col6 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1519,6 +1549,9 @@ STAGE PLANS: condition expressions: 0 1 {KEY.reducesinkkey0} + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col5 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1645,6 +1678,9 @@ STAGE PLANS: condition expressions: 0 1 {KEY.reducesinkkey0} + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col5 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1777,6 +1813,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1903,6 +1942,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -2037,6 +2079,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -2163,6 +2208,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -2298,6 +2346,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} {VALUE._col0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0, _col1 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -2431,6 +2482,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} {VALUE._col0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0, _col1 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -2565,6 +2619,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string), value (type: string) + 1 key (type: string), value (type: string) outputColumnNames: _col0 Statistics: Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -2697,6 +2754,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string), value (type: string) + 1 key (type: string), value (type: string) outputColumnNames: _col0 Statistics: Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE Group By Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/cross_join.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/cross_join.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/cross_join.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/cross_join.q.out Thu Dec 11 17:34:07 2014 @@ -41,6 +41,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} 1 + keys: + 0 + 1 outputColumnNames: _col0 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -104,6 +107,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} 1 + keys: + 0 + 1 outputColumnNames: _col0 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -175,6 +181,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Select Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/cross_product_check_1.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/cross_product_check_1.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/cross_product_check_1.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/cross_product_check_1.q.out Thu Dec 11 17:34:07 2014 @@ -66,6 +66,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} {VALUE._col1} 1 {VALUE._col0} {VALUE._col1} + keys: + 0 + 1 outputColumnNames: _col0, _col1, _col5, _col6 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -148,6 +151,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} {VALUE._col0} 1 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0, _col1, _col5, _col6 Statistics: Num rows: 5 Data size: 57 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator @@ -162,6 +168,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} {VALUE._col1} {VALUE._col5} {VALUE._col6} 1 {VALUE._col0} {VALUE._col1} + keys: + 0 + 1 outputColumnNames: _col0, _col1, _col5, _col6, _col10, _col11 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -249,6 +258,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 5 Data size: 57 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -280,6 +292,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} {VALUE._col1} 1 {VALUE._col0} + keys: + 0 + 1 outputColumnNames: _col0, _col1, _col5 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -353,6 +368,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} 1 + keys: + 0 + 1 outputColumnNames: _col0 Statistics: Num rows: 11 Data size: 114 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -384,6 +402,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} {VALUE._col1} 1 {VALUE._col0} + keys: + 0 + 1 outputColumnNames: _col0, _col1, _col5 Statistics: Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -491,6 +512,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} 1 {VALUE._col0} + keys: + 0 + 1 outputColumnNames: _col0, _col1 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -512,6 +536,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Statistics: Num rows: 5 Data size: 57 Basic stats: COMPLETE Column stats: NONE Group By Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/dynamic_partition_pruning.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/dynamic_partition_pruning.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/dynamic_partition_pruning.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/dynamic_partition_pruning.q.out Thu Dec 11 17:34:07 2014 @@ -250,6 +250,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 ds (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -353,6 +356,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 ds (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -518,6 +524,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col2} 1 + keys: + 0 ds (type: string) + 1 ds (type: string) outputColumnNames: _col3 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator @@ -533,6 +542,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 _col3 (type: string) + 1 hr (type: string) Statistics: Num rows: 2420 Data size: 25709 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -658,6 +670,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col2} 1 + keys: + 0 ds (type: string) + 1 ds (type: string) outputColumnNames: _col3 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator @@ -673,6 +688,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 _col3 (type: string) + 1 hr (type: string) Statistics: Num rows: 2420 Data size: 25709 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -822,6 +840,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string), hr (type: string) + 1 ds (type: string), hr (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -925,6 +946,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string), hr (type: string) + 1 ds (type: string), hr (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -1056,6 +1080,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 ds (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -1159,6 +1186,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 ds (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -1291,6 +1321,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 UDFToDouble(hr) (type: double) + 1 UDFToDouble(UDFToInteger((hr / 2))) (type: double) Statistics: Num rows: 1100 Data size: 11686 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -1412,6 +1445,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 (hr * 2) (type: double) + 1 hr (type: double) Statistics: Num rows: 1100 Data size: 11686 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -1518,6 +1554,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 UDFToDouble(hr) (type: double) + 1 UDFToDouble(UDFToInteger((hr / 2))) (type: double) Statistics: Num rows: 1100 Data size: 11686 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -1624,6 +1663,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 (hr * 2) (type: double) + 1 hr (type: double) Statistics: Num rows: 1100 Data size: 11686 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -1758,6 +1800,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 UDFToString((hr * 2)) (type: string) + 1 UDFToString(hr) (type: string) Statistics: Num rows: 1100 Data size: 11686 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -1910,6 +1955,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 _col0 (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -2024,6 +2072,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col2} {VALUE._col3} 1 {VALUE._col0} {VALUE._col2} + keys: + 0 + 1 outputColumnNames: _col2, _col3, _col7, _col9 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Filter Operator @@ -2165,6 +2216,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} {KEY.reducesinkkey1} 1 {KEY.reducesinkkey0} {KEY.reducesinkkey1} + keys: + 0 ds (type: string), hr (type: string) + 1 ds (type: string), hr (type: string) outputColumnNames: _col2, _col3, _col7, _col9 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Filter Operator @@ -2272,6 +2326,9 @@ STAGE PLANS: condition expressions: 0 1 {VALUE._col0} + keys: + 0 ds (type: string) + 1 ds (type: string) outputColumnNames: _col8 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Filter Operator @@ -2376,6 +2433,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 ds (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -2458,6 +2518,9 @@ STAGE PLANS: condition expressions: 0 1 {VALUE._col0} + keys: + 0 ds (type: string) + 1 ds (type: string) outputColumnNames: _col8 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Filter Operator @@ -2596,6 +2659,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 ds (type: string) Statistics: Num rows: 1100 Data size: 11686 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator key expressions: '11' (type: string) @@ -2609,6 +2675,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 '11' (type: string) + 1 '11' (type: string) Statistics: Num rows: 1210 Data size: 12854 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -2718,6 +2787,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 ds (type: string) Statistics: Num rows: 0 Data size: 0 Basic stats: NONE Column stats: NONE Reduce Output Operator key expressions: '13' (type: string) @@ -2731,6 +2803,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 '13' (type: string) + 1 '13' (type: string) Statistics: Num rows: 1 Data size: 5 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -2856,6 +2931,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 _col0 (type: string) Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator aggregations: count() @@ -3039,6 +3117,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 ds (type: string) + 1 _col0 (type: string) outputColumnNames: _col2 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -3297,6 +3378,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 _col0 (type: string) + 1 _col0 (type: string) outputColumnNames: _col0 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -4561,6 +4645,9 @@ STAGE PLANS: condition expressions: 0 1 {VALUE._col0} + keys: + 0 ds (type: string) + 1 ds (type: string) outputColumnNames: _col8 Statistics: Num rows: 2200 Data size: 23372 Basic stats: COMPLETE Column stats: NONE Filter Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/filter_join_breaktask.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/filter_join_breaktask.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/filter_join_breaktask.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/filter_join_breaktask.q.out Thu Dec 11 17:34:07 2014 @@ -357,6 +357,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 {VALUE._col0} + keys: + 0 key (type: int) + 1 key (type: int) outputColumnNames: _col0, _col7 Position of Big Table: 0 Statistics: Num rows: 14 Data size: 119 Basic stats: COMPLETE Column stats: NONE @@ -377,6 +380,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} 1 {KEY.reducesinkkey0} + keys: + 0 _col7 (type: string) + 1 value (type: string) outputColumnNames: _col0, _col13 Position of Big Table: 0 Statistics: Num rows: 27 Data size: 232 Basic stats: COMPLETE Column stats: NONE Modified: hive/trunk/ql/src/test/results/clientpositive/tez/join0.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/join0.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/join0.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/join0.q.out Thu Dec 11 17:34:07 2014 @@ -67,6 +67,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} {VALUE._col1} 1 {VALUE._col0} {VALUE._col1} + keys: + 0 + 1 outputColumnNames: _col0, _col1, _col2, _col3 Statistics: Num rows: 182 Data size: 1939 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/join1.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/join1.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/join1.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/join1.q.out Thu Dec 11 17:34:07 2014 @@ -66,6 +66,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 {VALUE._col0} + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0, _col6 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Select Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/join_nullsafe.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/join_nullsafe.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/join_nullsafe.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/join_nullsafe.q.out Thu Dec 11 17:34:07 2014 @@ -65,6 +65,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} {VALUE._col0} 1 {VALUE._col0} {KEY.reducesinkkey0} + keys: + 0 key (type: int) + 1 value (type: int) nullSafes: [true] outputColumnNames: _col0, _col1, _col5, _col6 Statistics: Num rows: 3 Data size: 28 Basic stats: COMPLETE Column stats: NONE @@ -172,6 +175,10 @@ STAGE PLANS: 0 {KEY.reducesinkkey0} {VALUE._col0} 1 {VALUE._col0} {KEY.reducesinkkey0} 2 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 key (type: int) + 1 value (type: int) + 2 key (type: int) outputColumnNames: _col0, _col1, _col5, _col6, _col10, _col11 Statistics: Num rows: 4 Data size: 37 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -260,6 +267,10 @@ STAGE PLANS: 0 {KEY.reducesinkkey0} {VALUE._col0} 1 {VALUE._col0} {KEY.reducesinkkey0} 2 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 key (type: int) + 1 value (type: int) + 2 key (type: int) nullSafes: [true] outputColumnNames: _col0, _col1, _col5, _col6, _col10, _col11 Statistics: Num rows: 6 Data size: 57 Basic stats: COMPLETE Column stats: NONE @@ -382,6 +393,10 @@ STAGE PLANS: 0 {KEY.reducesinkkey0} {KEY.reducesinkkey1} 1 {KEY.reducesinkkey1} {KEY.reducesinkkey0} 2 {KEY.reducesinkkey0} {KEY.reducesinkkey1} + keys: + 0 key (type: int), value (type: int) + 1 value (type: int), key (type: int) + 2 key (type: int), value (type: int) nullSafes: [true, false] outputColumnNames: _col0, _col1, _col5, _col6, _col10, _col11 Statistics: Num rows: 4 Data size: 37 Basic stats: COMPLETE Column stats: NONE @@ -468,6 +483,10 @@ STAGE PLANS: 0 {KEY.reducesinkkey0} {KEY.reducesinkkey1} 1 {KEY.reducesinkkey1} {KEY.reducesinkkey0} 2 {KEY.reducesinkkey0} {KEY.reducesinkkey1} + keys: + 0 key (type: int), value (type: int) + 1 value (type: int), key (type: int) + 2 key (type: int), value (type: int) nullSafes: [true, true] outputColumnNames: _col0, _col1, _col5, _col6, _col10, _col11 Statistics: Num rows: 6 Data size: 57 Basic stats: COMPLETE Column stats: NONE @@ -1601,6 +1620,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} 1 {VALUE._col0} + keys: + 0 null (type: void) + 1 null (type: void) nullSafes: [true] outputColumnNames: _col1, _col5 Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: NONE Modified: hive/trunk/ql/src/test/results/clientpositive/tez/limit_pushdown.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/limit_pushdown.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/limit_pushdown.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/limit_pushdown.q.out Thu Dec 11 17:34:07 2014 @@ -887,6 +887,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} {VALUE._col0} 1 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 _col0 (type: string) + 1 _col0 (type: string) outputColumnNames: _col0, _col1, _col2, _col3 Statistics: Num rows: 2 Data size: 22 Basic stats: COMPLETE Column stats: NONE Select Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/metadataonly1.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/metadataonly1.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/metadataonly1.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/metadataonly1.q.out Thu Dec 11 17:34:07 2014 @@ -872,6 +872,9 @@ STAGE PLANS: condition expressions: 0 1 + keys: + 0 ds (type: string) + 1 _col0 (type: string) Position of Big Table: 0 Statistics: Num rows: 1 Data size: 92 Basic stats: COMPLETE Column stats: NONE Group By Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/mrr.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/mrr.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/mrr.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/mrr.q.out Thu Dec 11 17:34:07 2014 @@ -441,6 +441,9 @@ STAGE PLANS: condition expressions: 0 1 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col5, _col6 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -1394,6 +1397,10 @@ STAGE PLANS: 0 {KEY.reducesinkkey0} {VALUE._col0} 1 {KEY.reducesinkkey0} {VALUE._col0} 2 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 _col0 (type: string) + 1 _col0 (type: string) + 2 _col0 (type: string) outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/optimize_nullscan.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/optimize_nullscan.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/optimize_nullscan.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/optimize_nullscan.q.out Thu Dec 11 17:34:07 2014 @@ -515,6 +515,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 {KEY.reducesinkkey0} + keys: + 0 _col0 (type: string) + 1 _col0 (type: string) outputColumnNames: _col0, _col1 Position of Big Table: 0 Statistics: Num rows: 0 Data size: 0 Basic stats: NONE Column stats: NONE @@ -1382,6 +1385,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} 1 {VALUE._col0} + keys: + 0 + 1 outputColumnNames: _col0, _col1 Position of Big Table: 0 Statistics: Num rows: 0 Data size: 0 Basic stats: NONE Column stats: NONE @@ -1688,6 +1694,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0 Position of Big Table: 0 Select Operator @@ -1926,6 +1935,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} {KEY.reducesinkkey0} 1 {VALUE._col0} {KEY.reducesinkkey0} + keys: + 0 value (type: string) + 1 value (type: string) outputColumnNames: _col0, _col1, _col5, _col6 Position of Big Table: 0 Statistics: Num rows: 0 Data size: 0 Basic stats: NONE Column stats: NONE Modified: hive/trunk/ql/src/test/results/clientpositive/tez/skewjoin.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/skewjoin.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/skewjoin.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/skewjoin.q.out Thu Dec 11 17:34:07 2014 @@ -126,6 +126,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey0} 1 {VALUE._col0} + keys: + 0 key (type: string) + 1 key (type: string) outputColumnNames: _col0, _col6 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -269,6 +272,11 @@ STAGE PLANS: 1 {KEY.reducesinkkey0} {VALUE._col0} 2 {KEY.reducesinkkey0} {VALUE._col0} 3 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 key (type: string) + 1 key (type: string) + 2 key (type: string) + 3 key (type: string) outputColumnNames: _col0, _col1, _col5, _col6, _col10, _col11, _col15, _col16 Statistics: Num rows: 0 Data size: 0 Basic stats: NONE Column stats: NONE Select Operator @@ -401,6 +409,11 @@ STAGE PLANS: 1 {KEY.reducesinkkey0} {VALUE._col0} 2 {KEY.reducesinkkey0} {VALUE._col0} 3 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 key (type: string) + 1 key (type: string) + 2 key (type: string) + 3 key (type: string) outputColumnNames: _col0, _col1, _col5, _col6, _col10, _col11, _col15, _col16 Statistics: Num rows: 0 Data size: 0 Basic stats: NONE Column stats: NONE Select Operator @@ -494,6 +507,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} {VALUE._col1} 1 {VALUE._col0} + keys: + 0 UDFToDouble(key) (type: double) + 1 (key + 1) (type: double) outputColumnNames: _col0, _col1, _col5 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -610,6 +626,9 @@ STAGE PLANS: condition expressions: 0 1 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 _col0 (type: string) + 1 _col0 (type: string) outputColumnNames: _col2, _col3 Statistics: Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -734,6 +753,9 @@ STAGE PLANS: condition expressions: 0 1 {KEY.reducesinkkey0} {VALUE._col0} + keys: + 0 _col0 (type: string), UDFToDouble(substring(_col1, 5)) (type: double) + 1 _col0 (type: string), (substring(_col1, 5) + 1) (type: double) outputColumnNames: _col2, _col3 Statistics: Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -885,6 +907,10 @@ STAGE PLANS: 0 {KEY.reducesinkkey0} 1 {VALUE._col0} 2 + keys: + 0 _col0 (type: string) + 1 _col0 (type: string) + 2 _col0 (type: string) outputColumnNames: _col0, _col3 Statistics: Num rows: 121 Data size: 1284 Basic stats: COMPLETE Column stats: NONE Group By Operator @@ -994,6 +1020,9 @@ STAGE PLANS: condition expressions: 0 {VALUE._col0} 1 {VALUE._col1} + keys: + 0 (key + 1) (type: double) + 1 UDFToDouble(key) (type: double) outputColumnNames: _col0, _col6 Statistics: Num rows: 0 Data size: 33 Basic stats: PARTIAL Column stats: NONE Group By Operator Modified: hive/trunk/ql/src/test/results/clientpositive/tez/subquery_exists.q.out URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/subquery_exists.q.out?rev=1644709&r1=1644708&r2=1644709&view=diff ============================================================================== --- hive/trunk/ql/src/test/results/clientpositive/tez/subquery_exists.q.out (original) +++ hive/trunk/ql/src/test/results/clientpositive/tez/subquery_exists.q.out Thu Dec 11 17:34:07 2014 @@ -76,6 +76,9 @@ STAGE PLANS: condition expressions: 0 {KEY.reducesinkkey1} {KEY.reducesinkkey0} 1 + keys: + 0 value (type: string), key (type: string) + 1 _col0 (type: string), _col1 (type: string) outputColumnNames: _col0, _col1 Statistics: Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE Select Operator