fix multi cf polute query

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/direct_load/protocol/v0/ObDirectLoadProtocolV0.java

@@ -69,10 +69,10 @@ public void checkIsSupported(ObDirectLoadStatement statement) throws ObDirectLoa
             logger.warn("partition names in ob version " + ObGlobal.getObVsnString(obVersion)
                         + "is not supported, minimum version required is "
                         + ObGlobal.getObVsnString(OB_VERSION_4_3_5_0));
-            throw new ObDirectLoadNotSupportedException("partition names in ob version "
-                                                    + ObGlobal.getObVsnString(obVersion)
-                                                    + " is not supported, minimum version required is "
-                                                    + ObGlobal.getObVsnString(OB_VERSION_4_3_5_0));
+            throw new ObDirectLoadNotSupportedException(
+                "partition names in ob version " + ObGlobal.getObVsnString(obVersion)
+                        + " is not supported, minimum version required is "
+                        + ObGlobal.getObVsnString(OB_VERSION_4_3_5_0));
         }
     }
 

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

@@ -121,14 +121,14 @@ public void addTabletOperation(ObTableTabletOp tabletOp) {
     public void setLsOperation(ObTableLSOperation lsOperation) {
         this.lsOperation = lsOperation;
     }
-    
+
     /*
      * Get entity type.
      */
     public ObTableEntityType getEntityType() {
         return entityType;
     }
-    
+
     /*
      * Set entity type.
      */

src/main/java/com/alipay/oceanbase/rpc/table/ObHBaseParams.java

@@ -23,11 +23,11 @@
 import static com.alipay.oceanbase.rpc.util.Serialization.encodeObUniVersionHeader;
 
 public class ObHBaseParams extends ObKVParamsBase {
-    int                      caching                    = -1;    // limit the number of for each rpc call
-    int                      callTimeout                = -1;    // scannerLeasePeriodTimeout in hbase, client rpc timeout
-    boolean                  allowPartialResults        = true;  // whether allow partial row return or not
-    boolean                  isCacheBlock               = false; // whether enable server block cache and row cache or not
-    boolean                  checkExistenceOnly         = false; // check the existence only
+    int                      caching                    = -1;     // limit the number of for each rpc call
+    int                      callTimeout                = -1;     // scannerLeasePeriodTimeout in hbase, client rpc timeout
+    boolean                  allowPartialResults        = true;   // whether allow partial row return or not
+    boolean                  isCacheBlock               = false;  // whether enable server block cache and row cache or not
+    boolean                  checkExistenceOnly         = false;  // check the existence only
     String                   hbaseVersion               = "1.3.6";
 
     private static final int FLAG_ALLOW_PARTIAL_RESULTS = 1 << 0;
@@ -120,7 +120,7 @@ public byte[] encode() {
         System.arraycopy(booleansToByteArray(), 0, bytes, idx, 1);
         idx += 1;
         System.arraycopy(Serialization.encodeVString(hbaseVersion), 0, bytes, idx,
-                Serialization.getNeedBytes(hbaseVersion));
+            Serialization.getNeedBytes(hbaseVersion));
         idx += Serialization.getNeedBytes(hbaseVersion);
 
         return bytes;
@@ -150,8 +150,8 @@ public String toString() {
         return "ObParams: {\n pType = " + pType + ", \n caching = " + caching
                + ", \n callTimeout = " + callTimeout + ", \n allowPartialResult = "
                + allowPartialResults + ", \n isCacheBlock = " + isCacheBlock
-               + ", \n checkExistenceOnly = " + checkExistenceOnly
-               + ", \n hbaseVersion = " + hbaseVersion  + "\n}\n";
+               + ", \n checkExistenceOnly = " + checkExistenceOnly + ", \n hbaseVersion = "
+               + hbaseVersion + "\n}\n";
     }
 
 }