fix checkstyle violation

Author: polyzos

fluss-client/src/main/java/org/apache/fluss/client/lookup/Lookup.java

@@ -99,11 +99,11 @@ default Lookup lookupBy(String... lookupColumnNames) {
      * lookup columns. By default, the lookup columns are the primary key columns, but can be
      * changed with ({@link #lookupBy(List)}) method.
      *
-     * <p>The returned lookuper accepts generic keys of type {@code K}. If a key is a POJO,
-     * the client implementation will convert it to an {@code InternalRow} based on the table
-     * schema and the active lookup columns.
+     * <p>The returned lookuper accepts generic keys of type {@code K}. If a key is a POJO, the
+     * client implementation will convert it to an {@code InternalRow} based on the table schema and
+     * the active lookup columns.
      *
      * @return the lookuper
      */
     <K> Lookuper<K> createLookuper();
-}
+}

fluss-client/src/main/java/org/apache/fluss/client/lookup/Lookuper.java

@@ -25,13 +25,12 @@
  * A lookuper performs key-based lookups against a primary key table, using either the full primary
  * key or a prefix of the primary key (when configured via {@code Lookup#lookupBy}).
  *
- * <p>This interface is generic on the key type {@code K}:
- * - When used in row mode, implementations are typically declared as {@code Lookuper<InternalRow>}
- *   and accept an {@link org.apache.fluss.row.InternalRow} containing the key fields in the
- *   configured order.
- * - When used with POJO keys, client-provided lookuper instances can also accept a POJO key type
- *   (for example {@code Lookuper<MyKeyPojo>}) and will transparently convert the POJO to an
- *   {@code InternalRow} using the table schema and active lookup columns.
+ * <p>This interface is generic on the key type {@code K}: - When used in row mode, implementations
+ * are typically declared as {@code Lookuper<InternalRow>} and accept an {@link
+ * org.apache.fluss.row.InternalRow} containing the key fields in the configured order. - When used
+ * with POJO keys, client-provided lookuper instances can also accept a POJO key type (for example
+ * {@code Lookuper<MyKeyPojo>}) and will transparently convert the POJO to an {@code InternalRow}
+ * using the table schema and active lookup columns.
  *
  * <p>Usage examples:
  *
@@ -65,4 +64,4 @@ public interface Lookuper<K> {
      * @return the result of lookup.
      */
     CompletableFuture<LookupResult> lookup(K lookupKey);
-}
+}

fluss-client/src/main/java/org/apache/fluss/client/lookup/TableLookup.java

@@ -61,9 +61,10 @@ public <K> Lookuper<K> createLookuper() {
         if (lookupColumnNames == null) {
             lookuper = new PrimaryKeyLookuper(tableInfo, metadataUpdater, lookupClient);
         } else {
-            lookuper = new PrefixKeyLookuper(
-                    tableInfo, metadataUpdater, lookupClient, lookupColumnNames);
+            lookuper =
+                    new PrefixKeyLookuper(
+                            tableInfo, metadataUpdater, lookupClient, lookupColumnNames);
         }
         return new TypedLookuper<K>(lookuper, tableInfo, lookupColumnNames);
     }
-}
+}

fluss-client/src/main/java/org/apache/fluss/client/lookup/TypedLookuper.java

@@ -23,23 +23,26 @@
 import org.apache.fluss.types.RowType;
 
 import javax.annotation.Nullable;
+
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 
 /**
- * Decorator for {@link Lookuper} that enables generic key lookup via {@link Lookuper#lookup(Object)}.
- * Converts POJO keys to {@link InternalRow} using existing converters based on table schema and
- * active lookup columns, and directly delegates when the key is already an {@link InternalRow}.
+ * Decorator for {@link Lookuper} that enables generic key lookup via {@link
+ * Lookuper#lookup(Object)}. Converts POJO keys to {@link InternalRow} using existing converters
+ * based on table schema and active lookup columns, and directly delegates when the key is already
+ * an {@link InternalRow}.
  */
 final class TypedLookuper<K> implements Lookuper<K> {
 
     private final Lookuper<InternalRow> delegate;
     private final TableInfo tableInfo;
     @Nullable private final List<String> lookupColumnNames;
 
-    TypedLookuper(Lookuper<InternalRow> delegate,
-                           TableInfo tableInfo,
-                           @Nullable List<String> lookupColumnNames) {
+    TypedLookuper(
+            Lookuper<InternalRow> delegate,
+            TableInfo tableInfo,
+            @Nullable List<String> lookupColumnNames) {
         this.delegate = delegate;
         this.tableInfo = tableInfo;
         this.lookupColumnNames = lookupColumnNames;

fluss-client/src/main/java/org/apache/fluss/client/table/scanner/Scan.java

@@ -88,4 +88,4 @@ public interface Scan {
      * #limit(int)} and only support for Primary Key Tables.
      */
     BatchScanner createBatchScanner(TableBucket tableBucket, long snapshotId);
-}
+}

fluss-client/src/main/java/org/apache/fluss/client/table/scanner/ScanRecord.java

@@ -89,4 +89,4 @@ public int hashCode() {
     public String toString() {
         return changeType.shortString() + value + "@" + offset;
     }
-}
+}

fluss-client/src/main/java/org/apache/fluss/client/table/scanner/TableScan.java

@@ -158,4 +158,4 @@ public BatchScanner createBatchScanner(TableBucket tableBucket, long snapshotId)
                 tableInfo.getTableConfig().getKvFormat(),
                 conn.getOrCreateRemoteFileDownloader());
     }
-}
+}

fluss-client/src/main/java/org/apache/fluss/client/table/scanner/log/CompletedFetch.java

@@ -255,4 +255,4 @@ private void maybeCloseRecordStream() {
             records = null;
         }
     }
-}
+}

fluss-client/src/main/java/org/apache/fluss/client/table/scanner/log/LogFetchCollector.java

@@ -20,7 +20,6 @@
 import org.apache.fluss.annotation.Internal;
 import org.apache.fluss.client.metadata.MetadataUpdater;
 import org.apache.fluss.client.table.scanner.ScanRecord;
-import org.apache.fluss.row.InternalRow;
 import org.apache.fluss.config.ConfigOptions;
 import org.apache.fluss.config.Configuration;
 import org.apache.fluss.exception.AuthorizationException;
@@ -30,6 +29,7 @@
 import org.apache.fluss.metadata.TablePath;
 import org.apache.fluss.record.LogRecord;
 import org.apache.fluss.record.LogRecordBatch;
+import org.apache.fluss.row.InternalRow;
 import org.apache.fluss.rpc.protocol.ApiError;
 import org.apache.fluss.rpc.protocol.Errors;
 
@@ -84,7 +84,8 @@ public LogFetchCollector(
      * @throws LogOffsetOutOfRangeException If there is OffsetOutOfRange error in fetchResponse and
      *     the defaultResetPolicy is NONE
      */
-    public Map<TableBucket, List<ScanRecord<InternalRow>>> collectFetch(final LogFetchBuffer logFetchBuffer) {
+    public Map<TableBucket, List<ScanRecord<InternalRow>>> collectFetch(
+            final LogFetchBuffer logFetchBuffer) {
         Map<TableBucket, List<ScanRecord<InternalRow>>> fetched = new HashMap<>();
         int recordsRemaining = maxPollRecords;
 
@@ -116,7 +117,8 @@ public Map<TableBucket, List<ScanRecord<InternalRow>>> collectFetch(final LogFet
 
                     logFetchBuffer.poll();
                 } else {
-                    List<ScanRecord<InternalRow>> records = fetchRecords(nextInLineFetch, recordsRemaining);
+                    List<ScanRecord<InternalRow>> records =
+                            fetchRecords(nextInLineFetch, recordsRemaining);
                     if (!records.isEmpty()) {
                         TableBucket tableBucket = nextInLineFetch.tableBucket;
                         List<ScanRecord<InternalRow>> currentRecords = fetched.get(tableBucket);
@@ -147,7 +149,8 @@ public Map<TableBucket, List<ScanRecord<InternalRow>>> collectFetch(final LogFet
         return fetched;
     }
 
-    private List<ScanRecord<InternalRow>> fetchRecords(CompletedFetch nextInLineFetch, int maxRecords) {
+    private List<ScanRecord<InternalRow>> fetchRecords(
+            CompletedFetch nextInLineFetch, int maxRecords) {
         TableBucket tb = nextInLineFetch.tableBucket;
         Long offset = logScannerStatus.getBucketOffset(tb);
         if (offset == null) {
@@ -290,4 +293,4 @@ private void handleInitializeErrors(
                             error, fetchOffset, tb, error.exception(errorMessage)));
         }
     }
-}
+}

fluss-client/src/main/java/org/apache/fluss/client/table/scanner/log/LogScannerImpl.java

@@ -303,4 +303,4 @@ public void close() {
             release();
         }
     }
-}
+}