mvn spotless apply.

Author: Sh-Zh-7

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/GroupedTopNRowNumberBuilder.java

@@ -145,7 +145,8 @@ protected TsBlock computeNext() {
               return endOfData();
             }
             return tsBlockBuilder.build(
-                new RunLengthEncodedColumn(TIME_COLUMN_TEMPLATE, tsBlockBuilder.getPositionCount()));
+                new RunLengthEncodedColumn(
+                    TIME_COLUMN_TEMPLATE, tsBlockBuilder.getPositionCount()));
           }
           currentGroupId++;
           currentGroupSize = groupedTopNRowNumberAccumulator.drainTo(currentGroupId, rowIdOutput);

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/RowReferenceTsBlockManager.java

@@ -57,7 +57,8 @@ public LoadCursor add(TsBlock tsBlock, int startingPosition) {
         "invalid startingPosition: %s",
         startingPosition);
 
-    TsBlockAccounting tsBlockAccounting = tsBlocks.allocateId(id -> new TsBlockAccounting(id, tsBlock));
+    TsBlockAccounting tsBlockAccounting =
+        tsBlocks.allocateId(id -> new TsBlockAccounting(id, tsBlock));
 
     tsBlockAccounting.lockTsBlock();
     currentCursor =
@@ -231,8 +232,8 @@ public long referencePosition(int position) {
     }
 
     /**
-     * Locks the current TsBlock so that it can't be compacted (thus allowing for stable position-based
-     * access).
+     * Locks the current TsBlock so that it can't be compacted (thus allowing for stable
+     * position-based access).
      */
     public void lockTsBlock() {
       lockedTsBlock = true;
@@ -307,14 +308,19 @@ public void compact() {
     }
 
     public long sizeOf() {
-      // Getting the size of a TsBlock forces a lazy TsBlock to be loaded, so only provide the size after
+      // Getting the size of a TsBlock forces a lazy TsBlock to be loaded, so only provide the size
+      // after
       // an explicit decision to load
       long loadedTsBlockSize = isTsBlockLoaded ? tsBlock.getSizeInBytes() : 0;
-      return TSBLOCK_ACCOUNTING_INSTANCE_SIZE + loadedTsBlockSize + RamUsageEstimator.sizeOf(rowIds);
+      return TSBLOCK_ACCOUNTING_INSTANCE_SIZE
+          + loadedTsBlockSize
+          + RamUsageEstimator.sizeOf(rowIds);
     }
   }
 
-  /** Buffer abstracting a mapping between row IDs and their associated TsBlock IDs and positions. */
+  /**
+   * Buffer abstracting a mapping between row IDs and their associated TsBlock IDs and positions.
+   */
   private static class RowIdBuffer {
     public static final long UNKNOWN_ID = -1;
     private static final long INSTANCE_SIZE =

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TopKRankingOperator.java

@@ -269,6 +269,9 @@ public long calculateRetainedSizeAfterCallingNext() {
 
   @Override
   public long ramBytesUsed() {
-    return INSTANCE_SIZE + MemoryEstimationHelper.getEstimatedSizeOfAccountableObject(inputOperator) + MemoryEstimationHelper.getEstimatedSizeOfAccountableObject(operatorContext) + (groupedTopNBuilder != null ? groupedTopNBuilder.getEstimatedSizeInBytes() : 0);
+    return INSTANCE_SIZE
+        + MemoryEstimationHelper.getEstimatedSizeOfAccountableObject(inputOperator)
+        + MemoryEstimationHelper.getEstimatedSizeOfAccountableObject(operatorContext)
+        + (groupedTopNBuilder != null ? groupedTopNBuilder.getEstimatedSizeInBytes() : 0);
   }
 }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/RemoveRedundantWindow.java

@@ -19,13 +19,14 @@
 
 package org.apache.iotdb.db.queryengine.plan.relational.planner.iterative.rule;
 
-import com.google.common.collect.ImmutableList;
 import org.apache.iotdb.db.queryengine.plan.relational.planner.iterative.Rule;
 import org.apache.iotdb.db.queryengine.plan.relational.planner.node.ValuesNode;
 import org.apache.iotdb.db.queryengine.plan.relational.planner.node.WindowNode;
 import org.apache.iotdb.db.queryengine.plan.relational.utils.matching.Captures;
 import org.apache.iotdb.db.queryengine.plan.relational.utils.matching.Pattern;
 
+import com.google.common.collect.ImmutableList;
+
 import static org.apache.iotdb.db.queryengine.plan.relational.planner.node.Patterns.window;
 import static org.apache.iotdb.db.queryengine.plan.relational.planner.optimizations.QueryCardinalityUtil.isEmpty;
 
@@ -40,9 +41,9 @@ public Pattern<WindowNode> getPattern() {
   @Override
   public Result apply(WindowNode window, Captures captures, Context context) {
     if (isEmpty(window.getChild(), context.getLookup())) {
-          return Result.ofPlanNode(new ValuesNode(window.getPlanNodeId(),
-     window.getOutputSymbols(), ImmutableList.of()));
-        }
+      return Result.ofPlanNode(
+          new ValuesNode(window.getPlanNodeId(), window.getOutputSymbols(), ImmutableList.of()));
+    }
     return Result.empty();
   }
 }