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/11/25 05:29:36 UTC
[iotdb] 03/03: Fix calculate
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch Fix_flush
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit efb2598e7bba4b0bb795bbc7d85050f7aa5dfea8
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu Nov 25 13:24:33 2021 +0800
Fix calculate
---
.../org/apache/iotdb/db/engine/memtable/AbstractMemTable.java | 8 ++------
.../apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java | 3 +--
2 files changed, 3 insertions(+), 8 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java b/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java
index 24c901e..c55a4a3 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java
@@ -92,9 +92,7 @@ public abstract class AbstractMemTable implements IMemTable {
private IWritableMemChunkGroup createMemChunkGroupIfNotExistAndGet(
String deviceId, List<IMeasurementSchema> schemaList) {
IWritableMemChunkGroup memChunkGroup =
- memTableMap.computeIfAbsent(
- deviceId,
- k -> new WritableMemChunkGroup());
+ memTableMap.computeIfAbsent(deviceId, k -> new WritableMemChunkGroup());
for (IMeasurementSchema schema : schemaList) {
if (!memChunkGroup.contains(schema.getMeasurementId())) {
seriesNumber++;
@@ -107,9 +105,7 @@ public abstract class AbstractMemTable implements IMemTable {
private IWritableMemChunkGroup createAlignedMemChunkGroupIfNotExistAndGet(
String deviceId, List<IMeasurementSchema> schemaList) {
IWritableMemChunkGroup memChunkGroup =
- memTableMap.computeIfAbsent(
- deviceId,
- k -> new AlignedWritableMemChunkGroup(schemaList));
+ memTableMap.computeIfAbsent(deviceId, k -> new AlignedWritableMemChunkGroup(schemaList));
for (IMeasurementSchema schema : schemaList) {
if (!memChunkGroup.contains(schema.getMeasurementId())) {
seriesNumber++;
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java b/server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java
index 4a88394..fd6c408 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java
@@ -62,8 +62,7 @@ public class WritableMemChunkGroup implements IWritableMemChunkGroup {
private IWritableMemChunk createMemChunkIfNotExistAndGet(IMeasurementSchema schema) {
return memChunkMap.computeIfAbsent(
- schema.getMeasurementId(),
- k -> new WritableMemChunk(schema));
+ schema.getMeasurementId(), k -> new WritableMemChunk(schema));
}
@Override