You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2013/10/18 03:55:50 UTC
svn commit: r1533308 -
/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
Author: gunther
Date: Fri Oct 18 01:55:50 2013
New Revision: 1533308
URL: http://svn.apache.org/r1533308
Log:
HIVE-5587: Change MapRecordProcessor to use VectorMapOperator when necessary on Tez (Gunther Hagleitner)
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java?rev=1533308&r1=1533307&r2=1533308&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java Fri Oct 18 01:55:50 2013
@@ -34,6 +34,7 @@ import org.apache.hadoop.hive.ql.exec.Op
import org.apache.hadoop.hive.ql.exec.Utilities;
import org.apache.hadoop.hive.ql.exec.mr.ExecMapper.reportStats;
import org.apache.hadoop.hive.ql.exec.mr.ExecMapperContext;
+import org.apache.hadoop.hive.ql.exec.vector.VectorMapOperator;
import org.apache.hadoop.hive.ql.log.PerfLogger;
import org.apache.hadoop.hive.ql.plan.MapWork;
import org.apache.hadoop.hive.ql.plan.OperatorDesc;
@@ -94,7 +95,11 @@ public class MapRecordProcessor extends
l4j.info("Alias: "+s);
}
}
- mapOp = new MapOperator();
+ if (mapWork.getVectorMode()) {
+ mapOp = new VectorMapOperator();
+ } else {
+ mapOp = new MapOperator();
+ }
// initialize map operator
mapOp.setConf(mapWork);