hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hashut...@apache.org
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 GMT
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<Byte, List<ExprNodeDesc>> keyExprMap = new HashMap<Byte, List<ExprNodeDesc>>();
-
     // 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<Operator<? extends OperatorDesc>, 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<List<ReduceSinkOperator>, Map<Byte, List<ExprNodeDesc>>> 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<Byte, List<ExprNodeDesc>> keyExprMap = new HashMap<Byte, List<ExprNodeDesc>>();
+
+    for (pos = 0; pos < op.getParentOperators().size(); pos++) {
+      ReduceSinkOperator inputRS = oldReduceSinkParentOps.get(pos);
+      List<ExprNodeDesc> keyCols = inputRS.getConf().getKeyCols();
+      keyExprMap.put(pos, keyCols);
+    }
+
+    return new ObjectPair<List<ReduceSinkOperator>, Map<Byte,List<ExprNodeDesc>>>(oldReduceSinkParentOps, keyExprMap);
+  }
+
+  public static MapJoinDesc getMapJoinDesc(HiveConf hconf,
+      LinkedHashMap<Operator<? extends OperatorDesc>, 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<String, ExprNodeDesc> colExprMap = op.getColumnExprMap();
     List<ColumnInfo> schema = new ArrayList<ColumnInfo>(op.getSchema().getSignature());
     Map<Byte, List<ExprNodeDesc>> valueExprs = op.getConf().getExprs();
     Map<Byte, List<ExprNodeDesc>> newValueExprs = new HashMap<Byte, List<ExprNodeDesc>>();
+
+    ObjectPair<List<ReduceSinkOperator>, Map<Byte,List<ExprNodeDesc>>> pair = getKeys(joinTree, op);
+    List<ReduceSinkOperator> oldReduceSinkParentOps = pair.getFirst();
     for (Map.Entry<Byte, List<ExprNodeDesc>> entry : valueExprs.entrySet()) {
       byte tag = entry.getKey();
       Operator<?> terminal = oldReduceSinkParentOps.get(tag);
@@ -1095,15 +1109,13 @@ public class MapJoinProcessor implements
     Map<Byte, int[]> valueIndices = new HashMap<Byte, int[]>();
 
     // get the join keys from old parent ReduceSink operators
-    Map<Byte, List<ExprNodeDesc>> keyExprMap = new HashMap<Byte, List<ExprNodeDesc>>();
+    Map<Byte, List<ExprNodeDesc>> keyExprMap = pair.getSecond();
 
     // construct valueTableDescs and valueFilteredTableDescs
     List<TableDesc> valueTableDescs = new ArrayList<TableDesc>();
     List<TableDesc> valueFilteredTableDescs = new ArrayList<TableDesc>();
     int[][] filterMap = desc.getFilterMap();
-    for (pos = 0; pos < op.getParentOperators().size(); pos++) {
-      ReduceSinkOperator inputRS = oldReduceSinkParentOps.get(pos);
-      List<ExprNodeDesc> keyCols = inputRS.getConf().getKeyCols();
+    for (byte pos = 0; pos < op.getParentOperators().size(); pos++) {
       List<ExprNodeDesc> 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<ExprNodeDesc> valueColsInValueExpr = new ArrayList<ExprNodeDesc>();
         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<Byte, List<ExprNodeDesc>> 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



Mime
View raw message