You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2013/04/30 07:09:24 UTC
svn commit: r1477473 - in /hive/trunk:
common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java
ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java
Author: hashutosh
Date: Tue Apr 30 05:09:24 2013
New Revision: 1477473
URL: http://svn.apache.org/r1477473
Log:
HIVE-4438 : Remove unused join configuration parameter: hive.mapjoin.size.key (Gunther Hagleitner via Ashutosh Chauhan)
Modified:
hive/trunk/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java
Modified: hive/trunk/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
URL: http://svn.apache.org/viewvc/hive/trunk/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java?rev=1477473&r1=1477472&r2=1477473&view=diff
==============================================================================
--- hive/trunk/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java (original)
+++ hive/trunk/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java Tue Apr 30 05:09:24 2013
@@ -415,7 +415,6 @@ public class HiveConf extends Configurat
HIVEJOINEMITINTERVAL("hive.join.emit.interval", 1000),
HIVEJOINCACHESIZE("hive.join.cache.size", 25000),
HIVEMAPJOINBUCKETCACHESIZE("hive.mapjoin.bucket.cache.size", 100),
- HIVEMAPJOINROWSIZE("hive.mapjoin.size.key", 10000),
HIVEMAPJOINCACHEROWS("hive.mapjoin.cache.numrows", 25000),
HIVEGROUPBYMAPINTERVAL("hive.groupby.mapaggr.checkinterval", 100000),
HIVEMAPAGGRHASHMEMORY("hive.map.aggr.hash.percentmemory", (float) 0.5),
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java?rev=1477473&r1=1477472&r2=1477473&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java Tue Apr 30 05:09:24 2013
@@ -53,7 +53,6 @@ public abstract class AbstractMapJoinOpe
protected transient List<ObjectInspector>[] joinKeysStandardObjectInspectors;
protected transient byte posBigTable = -1; // one of the tables that is not in memory
- transient int mapJoinRowsKey; // rows for a given key
protected transient RowContainer<ArrayList<Object>> emptyList = null;
@@ -104,9 +103,6 @@ public abstract class AbstractMapJoinOpe
!hasFilter(posBigTable), reporter);
storage[posBigTable] = bigPosRC;
- mapJoinRowsKey = HiveConf.getIntVar(hconf,
- HiveConf.ConfVars.HIVEMAPJOINROWSIZE);
-
List<? extends StructField> structFields = ((StructObjectInspector) outputObjInspector)
.getAllStructFieldRefs();
if (conf.getOutputColumnNames().size() < structFields.size()) {
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java?rev=1477473&r1=1477472&r2=1477473&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java Tue Apr 30 05:09:24 2013
@@ -70,7 +70,6 @@ public class HashTableSinkOperator exten
protected transient List<ObjectInspector>[] joinKeysStandardObjectInspectors;
protected transient int posBigTableAlias = -1; // one of the tables that is not in memory
- transient int mapJoinRowsKey; // rows for a given key
protected transient RowContainer<ArrayList<Object>> emptyList = null;