Add config hbase.zookeeper.znode.parent for hbase backend

Implement #107 Change-Id: Ic57fe5aaeedc1af91b05399097a4170a2b159f2e
apache · Jan 15, 2019 · 744a1b5 · 744a1b5
1 parent e84ce7a
commit 744a1b5
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 2 deletions.
diff --git a/hugegraph-dist/src/assembly/travis/hbase-site.xml b/hugegraph-dist/src/assembly/travis/hbase-site.xml
@@ -17,6 +17,10 @@
         <name>zookeeper.session.timeout</name>
         <value>1200000</value>
     </property>
+    <property>
+        <name>zookeeper.znode.parent</name>
+        <value>/hbase</value>
+    </property>
     <property>
         <name>hbase.zookeeper.property.tickTime</name>
         <value>6000</value>

diff --git a/hugegraph-hbase/src/main/java/com/baidu/hugegraph/backend/store/hbase/HbaseOptions.java b/hugegraph-hbase/src/main/java/com/baidu/hugegraph/backend/store/hbase/HbaseOptions.java
@@ -57,6 +57,14 @@ public static synchronized HbaseOptions instance() {
                     2181
             );
 
+    public static final ConfigOption<String> HBASE_ZNODE_PARENT =
+            new ConfigOption<>(
+                    "hbase.znode_parent",
+                    "The znode parent path of HBase zookeeper.",
+                    disallowEmpty(),
+                    "/hbase"
+            );
+
     public static final ConfigOption<Integer> HBASE_THREADS_MAX =
             new ConfigOption<>(
                     "hbase.threads_max",

diff --git a/hugegraph-hbase/src/main/java/com/baidu/hugegraph/backend/store/hbase/HbaseSessions.java b/hugegraph-hbase/src/main/java/com/baidu/hugegraph/backend/store/hbase/HbaseSessions.java
@@ -36,6 +36,7 @@
 import org.apache.hadoop.hbase.CellScanner;
 import org.apache.hadoop.hbase.CellUtil;
 import org.apache.hadoop.hbase.HBaseConfiguration;
+import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.NamespaceDescriptor;
 import org.apache.hadoop.hbase.RegionMetrics;
 import org.apache.hadoop.hbase.ServerName;
@@ -93,10 +94,12 @@ private Table table(String table) throws IOException {
     public synchronized void open(HugeConfig conf) throws IOException {
         String hosts = conf.get(HbaseOptions.HBASE_HOSTS);
         int port = conf.get(HbaseOptions.HBASE_PORT);
+        String znodeParent = conf.get(HbaseOptions.HBASE_ZNODE_PARENT);
 
         Configuration config = HBaseConfiguration.create();
-        config.set("hbase.zookeeper.quorum", hosts);
-        config.set("hbase.zookeeper.property.clientPort", String.valueOf(port));
+        config.set(HConstants.ZOOKEEPER_QUORUM, hosts);
+        config.set(HConstants.ZOOKEEPER_CLIENT_PORT, String.valueOf(port));
+        config.set(HConstants.ZOOKEEPER_ZNODE_PARENT, znodeParent);
         // Set hbase.hconnection.threads.max 64 to avoid OOM(default value: 256)
         config.setInt("hbase.hconnection.threads.max",
                       conf.get(HbaseOptions.HBASE_THREADS_MAX));

diff --git a/hugegraph-test/src/main/resources/hugegraph.properties b/hugegraph-test/src/main/resources/hugegraph.properties
@@ -26,6 +26,7 @@ cassandra.read_timeout=120
 # hbase backend config
 hbase.hosts=localhost
 hbase.port=2181
+hbase.znode_parent=/hbase
 
 # mysql backend config
 jdbc.driver=com.mysql.jdbc.Driver