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 <[email protected]> Authored: Fri Jan 15 14:18:14 2016 +0800 Committer: mashengchen <[email protected]> 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;
