[Feat] Support 4.x observer

        Link: https://code.alibaba-inc.com/oceanbase/obkv-table-client-java/codereview/12086430

    * [Feat] Support 4.x observer

* [Fix] fix comments

Author: IHEII

src/main/java/com/alipay/oceanbase/rpc/ObClusterTableAsyncQuery.java

@@ -27,6 +27,7 @@
 import com.alipay.oceanbase.rpc.table.AbstractTableQuery;
 import com.alipay.oceanbase.rpc.table.ObTable;
 import com.alipay.oceanbase.rpc.table.ObTableClientQueryAsyncImpl;
+import com.alipay.oceanbase.rpc.table.ObTableParam;
 import com.alipay.oceanbase.rpc.table.api.TableQuery;
 
 public class ObClusterTableAsyncQuery extends AbstractTableQuery {
@@ -52,12 +53,12 @@ public QueryResultSet execute() throws Exception {
     }
 
     @Override
-    public QueryResultSet executeInit(ObPair<Long, ObTable> entry) throws Exception {
+    public QueryResultSet executeInit(ObPair<Long, ObTableParam> entry) throws Exception {
         return tableClientQuerySync.executeInit(entry);
     }
 
     @Override
-    public QueryResultSet executeNext(ObPair<Long, ObTable> entry) throws Exception {
+    public QueryResultSet executeNext(ObPair<Long, ObTableParam> entry) throws Exception {
         return tableClientQuerySync.executeNext(entry);
     }
 

src/main/java/com/alipay/oceanbase/rpc/ObClusterTableQuery.java

@@ -27,6 +27,7 @@
 import com.alipay.oceanbase.rpc.table.AbstractTableQuery;
 import com.alipay.oceanbase.rpc.table.ObTable;
 import com.alipay.oceanbase.rpc.table.ObTableClientQueryImpl;
+import com.alipay.oceanbase.rpc.table.ObTableParam;
 import com.alipay.oceanbase.rpc.table.api.TableQuery;
 
 import java.util.List;
@@ -78,12 +79,12 @@ public QueryResultSet execute() throws Exception {
     }
 
     @Override
-    public QueryResultSet executeInit(ObPair<Long, ObTable> entry) throws Exception {
+    public QueryResultSet executeInit(ObPair<Long, ObTableParam> entry) throws Exception {
         throw new IllegalArgumentException("not support executeInit");
     }
 
     @Override
-    public QueryResultSet executeNext(ObPair<Long, ObTable> entry) throws Exception {
+    public QueryResultSet executeNext(ObPair<Long, ObTableParam> entry) throws Exception {
         throw new IllegalArgumentException("not support executeNext");
     }
 

src/main/java/com/alipay/oceanbase/rpc/ObGlobal.java

@@ -0,0 +1,22 @@
+/*-
+ * #%L
+ * OBKV Table Client Framework
+ * %%
+ * Copyright (C) 2021 OceanBase
+ * %%
+ * OBKV Table Client Framework is licensed under Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ *          http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
+ * EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
+ * MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ * #L%
+ */
+
+package com.alipay.oceanbase.rpc;
+
+public class ObGlobal {
+    public static long OB_VERSION = 0;
+}

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

@@ -26,6 +26,7 @@
 import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.query.ObTableQuery;
 import com.alipay.oceanbase.rpc.stream.QueryResultSet;
 import com.alipay.oceanbase.rpc.table.ObTable;
+import com.alipay.oceanbase.rpc.table.ObTableParam;
 import com.alipay.oceanbase.rpc.table.api.TableQuery;
 import java.util.Arrays;
 import java.util.HashSet;
@@ -69,12 +70,12 @@ public QueryResultSet execute() {
     }
 
     @Override
-    public QueryResultSet executeInit(ObPair<Long, ObTable> entry) throws Exception {
+    public QueryResultSet executeInit(ObPair<Long, ObTableParam> entry) throws Exception {
         throw new IllegalArgumentException("not support executeInit");
     }
 
     @Override
-    public QueryResultSet executeNext(ObPair<Long, ObTable> entry) throws Exception {
+    public QueryResultSet executeNext(ObPair<Long, ObTableParam> entry) throws Exception {
         throw new IllegalArgumentException("not support executeNext");
     }
 

src/main/java/com/alipay/oceanbase/rpc/batch/QueryByBatch.java

@@ -32,4 +32,5 @@ public interface Constants {
     String OB_ROUTE_POLICY         = "ob_route_policy";
     String OCP_ROOT_SERVICE_ACTION = "ObRootServiceInfo";
     String OCP_IDC_REGION_ACTION   = "ObIDCRegionInfo";
+    Long   INVALID_TABLET_ID       = 0L;
 }

src/main/java/com/alipay/oceanbase/rpc/constant/Constants.java

@@ -127,7 +127,7 @@ public boolean isHashPart() {
      */
     public boolean isKeyPart() {
         return this.index == KEY_IMPLICIT.getIndex() || this.index == KEY_V2.getIndex()
-               || this.index == KEY_V3.getIndex();
+               || this.index == KEY_V3.getIndex() || this.index == KEY.getIndex();
     }
 
     /*

src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java

@@ -51,6 +51,21 @@ public ObPartitionLocation putPartitionLocationWithPartId(long partId,
         return partitionLocation.put(partId, ObpartitionLocation);
     }
 
+    /*
+     * Get partition location with tablet id.
+     */
+    public ObPartitionLocation getPartitionLocationWithTabletId(long tabletId) {
+        return partitionLocation.get(tabletId);
+    }
+
+    /*
+     * Put partition location with part id.
+     */
+    public ObPartitionLocation putPartitionLocationWithTabletId(long tabletId,
+                                                                ObPartitionLocation ObpartitionLocation) {
+        return partitionLocation.put(tabletId, ObpartitionLocation);
+    }
+
     /*
      * Prepare for weak read.
      * @param ldcLocation

src/main/java/com/alipay/oceanbase/rpc/location/model/partition/ObPartFuncType.java

@@ -30,6 +30,7 @@ public class ObPartitionInfo {
     private ObPartDesc           firstPartDesc = null;
     private ObPartDesc           subPartDesc   = null;
     private List<ObColumn>       partColumns   = new ArrayList<ObColumn>(1);
+    private Map<Long, Long>      partTabletIdMap = null;
     private Map<String, Long>    partNameIdMap = null;
     private Map<String, Integer> rowKeyElement = null;
 
@@ -150,4 +151,15 @@ public Map<String, Long> getPartNameIdMap() {
     public void setPartNameIdMap(Map<String, Long> partNameIdMap) {
         this.partNameIdMap = partNameIdMap;
     }
+
+    public Map<Long, Long> getPartTabletIdMap() {
+        return this.partTabletIdMap;
+    }
+
+    /*
+     * Set part tablet id map.
+     */
+    public void setPartTabletIdMap(Map<Long, Long> partTabletIdMap) {
+        this.partTabletIdMap = partTabletIdMap;
+    }
 }