spotless

Author: Pengzna

integration-test/src/test/java/org/apache/iotdb/db/it/iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java

@@ -21,8 +21,8 @@
 
 import org.apache.iotdb.confignode.it.regionmigration.IoTDBRegionOperationReliabilityITFramework;
 import org.apache.iotdb.consensus.ConsensusFactory;
-import org.apache.iotdb.isession.SessionConfig;
 import org.apache.iotdb.isession.ITableSession;
+import org.apache.iotdb.isession.SessionConfig;
 import org.apache.iotdb.it.env.EnvFactory;
 import org.apache.iotdb.it.env.cluster.node.DataNodeWrapper;
 import org.apache.iotdb.itbase.env.BaseEnv;
@@ -41,10 +41,10 @@
 import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Paths;
-import java.util.Arrays;
 import java.sql.Connection;
 import java.sql.ResultSet;
 import java.sql.Statement;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashSet;
 import java.util.List;
@@ -424,7 +424,9 @@ public void testObjectReplicaConsistency() throws Exception {
               .orElseThrow(() -> new AssertionError("Follower DataNode not found"));
 
       LOGGER.info(
-          "Stopping object-region leader DataNode {} (region {})", leaderDataNodeId, targetRegionId);
+          "Stopping object-region leader DataNode {} (region {})",
+          leaderDataNodeId,
+          targetRegionId);
       leaderNode.stopForcibly();
       Assert.assertFalse("Leader should be stopped", leaderNode.isAlive());
 
@@ -449,7 +451,8 @@ public void testObjectReplicaConsistency() throws Exception {
     }
   }
 
-  private Map<Integer, Pair<Integer, Set<Integer>>> waitForDataRegionMap(final Statement statement) {
+  private Map<Integer, Pair<Integer, Set<Integer>>> waitForDataRegionMap(
+      final Statement statement) {
     final AtomicReference<Map<Integer, Pair<Integer, Set<Integer>>>> dataRegionMapReference =
         new AtomicReference<>(Collections.emptyMap());
     Awaitility.await()
@@ -593,8 +596,7 @@ private void verifyObjectFileOnReplicas(
                 final DataNodeWrapper wrapper =
                     EnvFactory.getEnv()
                         .dataNodeIdToWrapper(dataNodeId)
-                        .orElseThrow(
-                            () -> new AssertionError("DataNode not found: " + dataNodeId));
+                        .orElseThrow(() -> new AssertionError("DataNode not found: " + dataNodeId));
                 Assert.assertTrue(
                     "Expected object file on DataNode "
                         + dataNodeId
@@ -612,8 +614,7 @@ private void verifyObjectFileOnReplicas(
   private boolean containsObjectFile(
       final DataNodeWrapper wrapper, final int regionId, final byte[] expectedContent)
       throws IOException {
-    final File objectRegionDir =
-        new File(wrapper.getDataNodeObjectDir(), String.valueOf(regionId));
+    final File objectRegionDir = new File(wrapper.getDataNodeObjectDir(), String.valueOf(regionId));
     return containsObjectFile(objectRegionDir, expectedContent);
   }
 

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/Base32ObjectPath.java

@@ -92,8 +92,7 @@ public Base32ObjectPath(Path path) {
         deviceIdSegments[i] = "";
       } else {
         deviceIdSegments[i] =
-            new String(
-                BaseEncoding.base32().omitPadding().decode(segment), StandardCharsets.UTF_8);
+            new String(BaseEncoding.base32().omitPadding().decode(segment), StandardCharsets.UTF_8);
       }
     }
     deviceID = IDeviceID.Factory.DEFAULT_FACTORY.create(deviceIdSegments);

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/ObjectTypeUtils.java

@@ -120,7 +120,8 @@ public static Binary replaceRegionIdForObjectBinary(int newRegionId, Binary orig
       final IObjectPath newObjectPath;
       if (objectPath instanceof PlainObjectPath) {
         newObjectPath =
-            new PlainObjectPath(objectPath.toString().replaceFirst(regionId + "", newRegionId + ""));
+            new PlainObjectPath(
+                objectPath.toString().replaceFirst(regionId + "", newRegionId + ""));
       } else {
         final String[] subPath = new String[path.getNameCount() - 1];
         for (int i = 1; i < path.getNameCount(); i++) {

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/iotconsensusv2/IoTConsensusV2Receiver.java

@@ -1535,9 +1535,7 @@ private TIoTConsensusV2TransferResp onRequest(
           // only update tsFileEventCount when tsFileEvent is first enqueue.
           tsFileEventCount.incrementAndGet();
         }
-        if (!isTransferTsFileSeal
-            && !isTransferTsFilePiece
-            && !shouldKeepRequestMetaAfterSuccess) {
+        if (!isTransferTsFileSeal && !isTransferTsFilePiece && !shouldKeepRequestMetaAfterSuccess) {
           WALEventCount.incrementAndGet();
         }
         reqExecutionOrderBuffer.add(requestMeta);

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/iotconsensusv2/handler/IoTConsensusV2TsFileInsertionEventHandler.java

@@ -221,8 +221,7 @@ private ObjectNode nextObjectNode(final ObjectFileDescriptor descriptor) {
         objectSize == 0
             ? 0
             : (int) Math.min(readFileBufferSize, objectSize - currentObjectFileOffset);
-    final boolean isEOF =
-        objectSize == 0 || currentObjectFileOffset + pieceLength >= objectSize;
+    final boolean isEOF = objectSize == 0 || currentObjectFileOffset + pieceLength >= objectSize;
     final ObjectNode objectNode =
         new ObjectNode(isEOF, currentObjectFileOffset, pieceLength, descriptor.getObjectPath());
 

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/iotconsensusv2/payload/request/IoTConsensusV2ObjectFileUtils.java

@@ -338,14 +338,11 @@ private static void collectObjectFileDescriptor(
       return;
     }
 
-    if (!TierManager.getInstance()
-        .getAbsoluteObjectFilePath(objectPathString, true)
-        .isPresent()) {
+    if (!TierManager.getInstance().getAbsoluteObjectFilePath(objectPathString, true).isPresent()) {
       throw new ObjectFileNotExist(objectPathString);
     }
 
-    objectFileDescriptors.put(
-        objectPathString, new ObjectFileDescriptor(objectSize, objectPath));
+    objectFileDescriptors.put(objectPathString, new ObjectFileDescriptor(objectSize, objectPath));
   }
 
   public static final class ObjectFileDescriptor {

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertTabletNode.java

@@ -491,7 +491,10 @@ private void handleObjectValue(
       final byte[] content = ReadWriteIOUtils.readBytes(buffer, buffer.remaining());
       final IObjectPath relativePath =
           IObjectPath.Factory.FACTORY.create(
-              entry.getKey().getRegionId().getId(), times[row], getDeviceID(row), measurements[column]);
+              entry.getKey().getRegionId().getId(),
+              times[row],
+              getDeviceID(row),
+              measurements[column]);
       final ObjectNode objectNode = new ObjectNode(isEOF, offset, content, relativePath);
       objectNode.setDataRegionReplicaSet(entry.getKey());
       result.add(objectNode);

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java

@@ -91,8 +91,8 @@
 import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.InsertRowsOfOneDeviceNode;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.InsertTabletNode;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.ObjectNode;
-import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.RelationalInsertRowNode;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.RelationalDeleteDataNode;
+import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.RelationalInsertRowNode;
 import org.apache.iotdb.db.queryengine.plan.relational.metadata.fetcher.cache.LastCacheLoadStrategy;
 import org.apache.iotdb.db.queryengine.plan.relational.metadata.fetcher.cache.TableDeviceSchemaCache;
 import org.apache.iotdb.db.queryengine.plan.relational.metadata.fetcher.cache.TreeDeviceSchemaCacheManager;