This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch ty-graduate
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/ty-graduate by this push:
     new 5edaa28  format code
5edaa28 is described below

commit 5edaa28cbbfadcf16bfdf3d13e344010f88d6aef
Author: JackieTien97 <[email protected]>
AuthorDate: Wed Mar 2 10:30:07 2022 +0800

    format code
---
 .../session/src/main/java/org/apache/iotdb/SessionExample.java   | 9 ---------
 .../java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java | 8 ++++++--
 2 files changed, 6 insertions(+), 11 deletions(-)

diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java 
b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
index 5c66cbd..261ae56 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -23,22 +23,13 @@ import org.apache.iotdb.rpc.IoTDBConnectionException;
 import org.apache.iotdb.rpc.StatementExecutionException;
 import org.apache.iotdb.session.Session;
 import org.apache.iotdb.session.SessionDataSet;
-import org.apache.iotdb.session.SessionDataSet.DataIterator;
-import org.apache.iotdb.session.template.MeasurementNode;
-import org.apache.iotdb.session.template.Template;
 import org.apache.iotdb.session.util.Version;
-import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
 import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
-import org.apache.iotdb.tsfile.utils.BitMap;
 import org.apache.iotdb.tsfile.write.record.Tablet;
 import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
 
-import java.io.IOException;
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 import java.util.Random;
 
 @SuppressWarnings("squid:S106")
diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java 
b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
index b1d0223..afbb6df 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
@@ -78,7 +78,6 @@ public class MemTableFlushTask {
 
   private static final AtomicLong totalIOTime = new AtomicLong(0);
 
-
   /**
    * @param memTable the memTable to flush
    * @param writer the writer where memTable will be flushed to (current 
tsfile writer or vm writer)
@@ -184,7 +183,12 @@ public class MemTableFlushTask {
     totalCostTime.addAndGet(costTime);
     totalEncodingTime.addAndGet(memSerializeTime);
     totalIOTime.addAndGet(ioTime);
-    LOGGER.info("Cumulative sort cost time: {}, encoding cost time: {}, io 
cost time: {}, flush cost time: {}", totalCostTime.get() - 
totalEncodingTime.get() - totalIOTime.get(), totalEncodingTime.get(), 
totalIOTime.get(), totalCostTime.get());
+    LOGGER.info(
+        "Cumulative sort cost time: {}, encoding cost time: {}, io cost time: 
{}, flush cost time: {}",
+        totalCostTime.get() - totalEncodingTime.get() - totalIOTime.get(),
+        totalEncodingTime.get(),
+        totalIOTime.get(),
+        totalCostTime.get());
   }
 
   /** encoding task (second task of pipeline) */

Reply via email to