You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2021/03/12 13:05:23 UTC
[iotdb] branch vectorMemTable updated: mvn spotless:apply
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch vectorMemTable
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/vectorMemTable by this push:
new bdf65e9 mvn spotless:apply
bdf65e9 is described below
commit bdf65e930e6221f17b7bd0f6ff001dac5e2264db
Author: HTHou <hh...@outlook.com>
AuthorDate: Fri Mar 12 21:04:52 2021 +0800
mvn spotless:apply
---
.../iotdb/db/engine/flush/MemTableFlushTask.java | 22 ++++++++++++++--------
1 file changed, 14 insertions(+), 8 deletions(-)
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 ff55f91..950d972 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
@@ -38,8 +38,6 @@ import org.apache.iotdb.tsfile.write.writer.RestorableTsFileIOWriter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import static org.apache.iotdb.db.rescon.PrimitiveArrayManager.ARRAY_SIZE;
-
import java.io.IOException;
import java.util.List;
import java.util.Map;
@@ -47,6 +45,8 @@ import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.LinkedBlockingQueue;
+import static org.apache.iotdb.db.rescon.PrimitiveArrayManager.ARRAY_SIZE;
+
public class MemTableFlushTask {
private static final Logger LOGGER = LoggerFactory.getLogger(MemTableFlushTask.class);
@@ -229,22 +229,28 @@ public class MemTableFlushTask {
int elementIndex = valueIndex % ARRAY_SIZE;
switch (dataTypes.get(i)) {
case TEXT:
- seriesWriterImpl.write(time, ((Binary[]) columnValues.get(arrayIndex))[elementIndex], false);
+ seriesWriterImpl.write(
+ time, ((Binary[]) columnValues.get(arrayIndex))[elementIndex], false);
break;
case FLOAT:
- seriesWriterImpl.write(time, ((float[]) columnValues.get(arrayIndex))[elementIndex], false);
+ seriesWriterImpl.write(
+ time, ((float[]) columnValues.get(arrayIndex))[elementIndex], false);
break;
case INT32:
- seriesWriterImpl.write(time, ((int[]) columnValues.get(arrayIndex))[elementIndex], false);
+ seriesWriterImpl.write(
+ time, ((int[]) columnValues.get(arrayIndex))[elementIndex], false);
break;
case INT64:
- seriesWriterImpl.write(time, ((long[]) columnValues.get(arrayIndex))[elementIndex], false);
+ seriesWriterImpl.write(
+ time, ((long[]) columnValues.get(arrayIndex))[elementIndex], false);
break;
case DOUBLE:
- seriesWriterImpl.write(time, ((double[]) columnValues.get(arrayIndex))[elementIndex], false);
+ seriesWriterImpl.write(
+ time, ((double[]) columnValues.get(arrayIndex))[elementIndex], false);
break;
case BOOLEAN:
- seriesWriterImpl.write(time, ((boolean[]) columnValues.get(arrayIndex))[elementIndex], false);
+ seriesWriterImpl.write(
+ time, ((boolean[]) columnValues.get(arrayIndex))[elementIndex], false);
break;
default:
break;