Merge pull request #218 from oceanbase/region_metrics

Implement Admin Region metrics

Author: JackShi148

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

@@ -220,8 +220,7 @@ public OHTable(Configuration configuration, String tableName) throws IOException
             DEFAULT_HBASE_HTABLE_THREAD_KEEP_ALIVE_TIME);
         this.executePool = createDefaultThreadPoolExecutor(1, maxThreads, keepAliveTime);
         OHConnectionConfiguration ohConnectionConf = new OHConnectionConfiguration(configuration);
-        int numRetries = configuration.getInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER,
-            HConstants.DEFAULT_HBASE_CLIENT_RETRIES_NUMBER);
+        int numRetries = ohConnectionConf.getNumRetries();
         this.obTableClient = ObTableClientManager.getOrCreateObTableClient(setUserDefinedNamespace(
             this.tableNameString, ohConnectionConf));
         this.obTableClient.setRpcExecuteTimeout(ohConnectionConf.getRpcTimeout());
@@ -273,8 +272,7 @@ public OHTable(Configuration configuration, final byte[] tableName,
         this.executePool = executePool;
         this.cleanupPoolOnClose = false;
         OHConnectionConfiguration ohConnectionConf = new OHConnectionConfiguration(configuration);
-        int numRetries = configuration.getInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER,
-            HConstants.DEFAULT_HBASE_CLIENT_RETRIES_NUMBER);
+        int numRetries = ohConnectionConf.getNumRetries();
         this.obTableClient = ObTableClientManager.getOrCreateObTableClient(setUserDefinedNamespace(
             this.tableNameString, ohConnectionConf));
         this.obTableClient.setRpcExecuteTimeout(ohConnectionConf.getRpcTimeout());
@@ -345,8 +343,7 @@ public OHTable(TableName tableName, Connection connection,
             DEFAULT_HBASE_HTABLE_PUT_WRITE_BUFFER_CHECK);
         this.writeBufferSize = connectionConfig.getWriteBufferSize();
         this.tableName = tableName.getName();
-        int numRetries = configuration.getInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER,
-            HConstants.DEFAULT_HBASE_CLIENT_RETRIES_NUMBER);
+        int numRetries = connectionConfig.getNumRetries();
         this.obTableClient = ObTableClientManager.getOrCreateObTableClient(setUserDefinedNamespace(
             this.tableNameString, connectionConfig));
         this.obTableClient.setRpcExecuteTimeout(rpcTimeout);
@@ -389,8 +386,7 @@ public OHTable(Connection connection, ObTableBuilderBase builder,
         this.putWriteBufferCheck = this.configuration.getInt(HBASE_HTABLE_PUT_WRITE_BUFFER_CHECK,
             DEFAULT_HBASE_HTABLE_PUT_WRITE_BUFFER_CHECK);
         this.writeBufferSize = connectionConfig.getWriteBufferSize();
-        int numRetries = configuration.getInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER,
-            HConstants.DEFAULT_HBASE_CLIENT_RETRIES_NUMBER);
+        int numRetries = connectionConfig.getNumRetries();
         this.obTableClient = ObTableClientManager.getOrCreateObTableClient(setUserDefinedNamespace(
             this.tableNameString, connectionConfig));
         this.obTableClient.setRpcExecuteTimeout(rpcTimeout);
@@ -462,7 +458,7 @@ private void finishSetUp() {
             WRITE_BUFFER_SIZE_DEFAULT);
     }
 
-    private OHConnectionConfiguration setUserDefinedNamespace(String tableNameString,
+    public static OHConnectionConfiguration setUserDefinedNamespace(String tableNameString,
                                                               OHConnectionConfiguration ohConnectionConf)
                                                                                                          throws IllegalArgumentException {
         if (tableNameString.indexOf(':') != -1) {

src/main/java/com/alipay/oceanbase/hbase/execute/AbstractObTableMetaExecutor.java

@@ -0,0 +1,31 @@
+package com.alipay.oceanbase.hbase.execute;
+
+import com.alipay.oceanbase.rpc.ObTableClient;
+import com.alipay.oceanbase.rpc.exception.ObTableException;
+import com.alipay.oceanbase.rpc.meta.ObTableMetaRequest;
+import com.alipay.oceanbase.rpc.meta.ObTableMetaResponse;
+import com.alipay.oceanbase.rpc.table.ObTable;
+
+import java.io.IOException;
+
+public abstract class AbstractObTableMetaExecutor<T> implements ObTableMetaExecutor<T> {
+
+    @Override
+    public T execute(ObTableClient client, ObTableMetaRequest request) throws IOException {
+        if (request.getMetaType() != getMetaType()) {
+            throw new IOException("Invalid meta type, expected " + getMetaType());
+        }
+        ObTable table = client.getRandomTable();
+        ObTableMetaResponse response;
+        try {
+            response = (ObTableMetaResponse) client.executeWithRetry(
+                    table,
+                    request,
+                    null /*tableName*/
+            );
+        } catch (Exception e) {
+            throw new IOException("Failed to execute request", e);
+        }
+        return parse(response);
+    }
+}

src/main/java/com/alipay/oceanbase/hbase/execute/ObTableMetaExecutor.java

@@ -0,0 +1,32 @@
+package com.alipay.oceanbase.hbase.execute;
+
+import com.alipay.oceanbase.rpc.ObTableClient;
+import com.alipay.oceanbase.rpc.meta.ObTableMetaRequest;
+import com.alipay.oceanbase.rpc.meta.ObTableMetaResponse;
+import com.alipay.oceanbase.rpc.meta.ObTableRpcMetaType;
+
+import java.io.IOException;
+
+public interface ObTableMetaExecutor<T> {
+    /**
+     * 执行元数据请求
+     * @param request 元数据请求
+     * @return 解析后的元数据对象
+     * @throws IOException 如果执行失败或解析失败
+     */
+    T execute(ObTableClient client, ObTableMetaRequest request) throws IOException;
+
+    /**
+     * 解析元数据响应, 用户需要重写
+     * @param response 元数据响应
+     * @return 解析后的元数据对象
+     * @throws IOException 如果解析失败
+     */
+    T parse(ObTableMetaResponse response) throws IOException;
+
+    /**
+     * 获取元信息类型, 用户需要重写
+     * @return 元信息类型
+     */
+    ObTableRpcMetaType getMetaType() throws IOException;
+}