skip entity serialize when hbase batch get

Author: GroundWu

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/ObTableSingleOp.java

@@ -64,13 +64,15 @@ public byte[] encode() {
         }
 
         // 4. encode entities
-        len = Serialization.getNeedBytes(entities.size());
-        System.arraycopy(Serialization.encodeVi64(entities.size()), 0, bytes, idx, len);
-        idx += len;
-        for (ObTableSingleOpEntity entity : entities) {
-            len = (int) entity.getPayloadSize();
-            System.arraycopy(entity.encode(), 0, bytes, idx, len);
+        if (!((singleOpType == ObTableOperationType.SCAN) && query.isHbaseQuery())) {
+            len = Serialization.getNeedBytes(entities.size());
+            System.arraycopy(Serialization.encodeVi64(entities.size()), 0, bytes, idx, len);
             idx += len;
+            for (ObTableSingleOpEntity entity : entities) {
+                len = (int) entity.getPayloadSize();
+                System.arraycopy(entity.encode(), 0, bytes, idx, len);
+                idx += len;
+            }
         }
 
         return bytes;
@@ -109,9 +111,11 @@ public long getPayloadContentSize() {
             if (ObTableOperationType.needEncodeQuery(singleOpType)) {
                 payloadContentSize += query.getPayloadSize();
             }
-            payloadContentSize += Serialization.getNeedBytes(entities.size());
-            for (ObTableSingleOpEntity entity : entities) {
-                payloadContentSize += entity.getPayloadSize();
+            if (!((singleOpType == ObTableOperationType.SCAN) && query.isHbaseQuery())) {
+                payloadContentSize += Serialization.getNeedBytes(entities.size());
+                for (ObTableSingleOpEntity entity : entities) {
+                    payloadContentSize += entity.getPayloadSize();
+                }
             }
             this.payLoadContentSize = payloadContentSize;
         }

src/main/java/com/alipay/oceanbase/rpc/util/Serialization.java

@@ -442,10 +442,13 @@ public static void encodeFloat(ObByteBuf buf, float f) {
      */
     public static int getNeedBytes(long l) {
         if (l < 0) {
-            return 10;  // 负数固定返回10字节
+            return 10;
         }
-        // 计算最高位的位置，然后除以8(一个字节8位)向上取整
-        return (Long.SIZE - Long.numberOfLeadingZeros(l) + 7) >>> 3;
+        if (l == 0) {
+            return 1;
+        }
+        // 计算有效位数，然后除以7向上取整
+        return (Long.SIZE - Long.numberOfLeadingZeros(l) + 6) / 7;
     }
 
     /**
@@ -455,10 +458,13 @@ public static int getNeedBytes(long l) {
      */
     public static int getNeedBytes(int l) {
         if (l < 0) {
-            return 5;  // 负数固定返回5字节
+            return 5;
+        }
+        if (l == 0) {
+            return 1;
         }
-        // 计算最高位的位置，然后除以8(一个字节8位)向上取整
-        return (Integer.SIZE - Integer.numberOfLeadingZeros(l) + 7) >>> 3;
+        // 计算有效位数，然后除以7向上取整
+        return (Integer.SIZE - Integer.numberOfLeadingZeros(l) + 6) / 7;
     }
 
     /**