hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xu...@apache.org
Subject svn commit: r1655927 - /hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
Date Fri, 30 Jan 2015 03:29:26 GMT
Author: xuefu
Date: Fri Jan 30 03:29:26 2015
New Revision: 1655927

URL: http://svn.apache.org/r1655927
Log:
HIVE-9515: Check hive.vectorized.execution.reduce.enabled [Spark Branch] (Jimmy via Xuefu)

Modified:
    hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java

Modified: hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java?rev=1655927&r1=1655926&r2=1655927&view=diff
==============================================================================
--- hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
(original)
+++ hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
Fri Jan 30 03:29:26 2015
@@ -318,7 +318,9 @@ public class Vectorizer implements Physi
         for (BaseWork baseWork : sparkWork.getAllWork()) {
           if (baseWork instanceof MapWork) {
             convertMapWork((MapWork) baseWork, false);
-          } else if (baseWork instanceof ReduceWork) {
+          } else if (baseWork instanceof ReduceWork
+              && HiveConf.getBoolVar(pctx.getConf(),
+                  HiveConf.ConfVars.HIVE_VECTORIZATION_REDUCE_ENABLED)) {
             convertReduceWork((ReduceWork) baseWork);
           }
         }



Mime
View raw message