You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafodion.apache.org by db...@apache.org on 2016/02/02 17:57:52 UTC
[18/25] incubator-trafodion git commit: Update HBaseClient.java
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 <ma...@gmail.com>
Authored: Fri Jan 15 14:18:14 2016 +0800
Committer: mashengchen <ma...@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;