format code

Author: JackShi148

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

@@ -2238,11 +2238,9 @@ public Pair<byte[][], byte[][]> getStartEndKeys() throws IOException {
 
     private BufferedMutator getBufferedMutator() throws IOException {
         if (this.mutator == null) {
-            this.mutator = new OHBufferedMutatorImpl(
-                    this.configuration,
-                    new BufferedMutatorParams(TableName.valueOf(this.tableNameString))
-                            .pool(this.executePool).writeBufferSize(this.writeBufferSize)
-                            .maxKeyValueSize(this.maxKeyValueSize), this);
+            this.mutator = new OHBufferedMutatorImpl(this.configuration, new BufferedMutatorParams(
+                TableName.valueOf(this.tableNameString)).pool(this.executePool)
+                .writeBufferSize(this.writeBufferSize).maxKeyValueSize(this.maxKeyValueSize), this);
         }
         return this.mutator;
     }

src/main/java/com/alipay/oceanbase/hbase/util/OHBufferedMutatorImpl.java

@@ -88,8 +88,11 @@ public OHBufferedMutatorImpl(OHConnectionImpl ohConnection, BufferedMutatorParam
         }
     }
 
-    public OHBufferedMutatorImpl(Configuration conf, BufferedMutatorParams params,
-                                 OHTable ohTable) throws IOException {
+    /**
+     * only used for OHTable get bufferedMutator
+     * */
+    public OHBufferedMutatorImpl(Configuration conf, BufferedMutatorParams params, OHTable ohTable)
+                                                                                                   throws IOException {
         // create an OHTable object to do batch work
         if (ohTable == null) {
             throw new ObTableUnexpectedException("The ohTable is null.");
@@ -106,9 +109,9 @@ public OHBufferedMutatorImpl(Configuration conf, BufferedMutatorParams params,
         this.operationTimeout = connectionConfig.getOperationTimeout();
 
         this.writeBufferSize = params.getWriteBufferSize() != OHConnectionImpl.BUFFERED_PARAM_UNSET ? params
-                .getWriteBufferSize() : connectionConfig.getWriteBufferSize();
+            .getWriteBufferSize() : connectionConfig.getWriteBufferSize();
         this.maxKeyValueSize = params.getMaxKeyValueSize() != OHConnectionImpl.BUFFERED_PARAM_UNSET ? params
-                .getMaxKeyValueSize() : connectionConfig.getMaxKeyValueSize();
+            .getMaxKeyValueSize() : connectionConfig.getMaxKeyValueSize();
 
     }