trafodion-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbirds...@apache.org
Subject [18/25] incubator-trafodion git commit: Update HBaseClient.java
Date Tue, 02 Feb 2016 16:57:52 GMT
Update HBaseClient.java

change CoprocessorUtils.addCoprocessor, add isMVCC as param

Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/a005ebf5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/a005ebf5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/a005ebf5

Branch: refs/heads/master
Commit: a005ebf5ccf75a374f034f8b63891a396c651ae9
Parents: b01d8cb
Author: mashengchen <mashengchen@gmail.com>
Authored: Fri Jan 15 14:18:14 2016 +0800
Committer: mashengchen <mashengchen@gmail.com>
Committed: Fri Jan 15 14:18:14 2016 +0800

----------------------------------------------------------------------
 core/sql/src/main/java/org/trafodion/sql/HBaseClient.java | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/a005ebf5/core/sql/src/main/java/org/trafodion/sql/HBaseClient.java
----------------------------------------------------------------------
diff --git a/core/sql/src/main/java/org/trafodion/sql/HBaseClient.java b/core/sql/src/main/java/org/trafodion/sql/HBaseClient.java
index fa68650..a363098 100644
--- a/core/sql/src/main/java/org/trafodion/sql/HBaseClient.java
+++ b/core/sql/src/main/java/org/trafodion/sql/HBaseClient.java
@@ -235,8 +235,7 @@ public class HBaseClient {
             if (logger.isDebugEnabled()) logger.debug("HBaseClient.create(" + tblName + ")
called, and MVCC is " + isMVCC + ".");
             cleanupCache(tblName);
             HTableDescriptor desc = new HTableDescriptor(tblName);
-            CoprocessorUtils.addCoprocessor(config.get("hbase.coprocessor.region.classes"),
desc);
-
+            CoprocessorUtils.addCoprocessor(config.get("hbase.coprocessor.region.classes"),
desc, isMVCC);
             for (int i = 0; i < colFamNameList.length ; i++) {
 		String  colFam = (String)colFamNameList[i];
                 HColumnDescriptor colDesc = new HColumnDescriptor(colFam);
@@ -488,8 +487,7 @@ public class HBaseClient {
             String trueStr = "TRUE";
             cleanupCache(tblName);
             HTableDescriptor desc = new HTableDescriptor(tblName);
-            CoprocessorUtils.addCoprocessor(config.get("hbase.coprocessor.region.classes"),
desc);
-
+            CoprocessorUtils.addCoprocessor(config.get("hbase.coprocessor.region.classes"),
desc, isMVCC);
             int defaultVersionsValue = 0;
             if (isMVCC)
                 defaultVersionsValue = DtmConst.MVCC_MAX_VERSION;


Mime
View raw message