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) */