You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by li...@apache.org on 2019/06/11 09:00:50 UTC
[incubator-iotdb] 01/02: add memtable pool
This is an automated email from the ASF dual-hosted git repository.
liurui pushed a commit to branch feature_async_close_memtablePool
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit fa31e399771bd1f342a873977ce2efe1a2ff6892
Author: liuruiyiyang <24...@qq.com>
AuthorDate: Tue Jun 11 16:35:15 2019 +0800
add memtable pool
---
.../src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java | 2 +-
.../main/java/org/apache/iotdb/db/engine/overflow/io/OverflowIO.java | 2 +-
.../java/org/apache/iotdb/db/engine/overflow/io/OverflowResource.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
index 1fb4a64..e86ff89 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
@@ -8,7 +8,7 @@ public class MemTablePool {
private static final Logger LOGGER = LoggerFactory.getLogger(MemTablePool.class);
private Stack<IMemTable> emptyMemTables;
- private int capacity = 10;
+ private int capacity = 20;
private int size = 0;
private static final MemTablePool INSTANCE = new MemTablePool();
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowIO.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowIO.java
index 90f0423..e5c908c 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowIO.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowIO.java
@@ -43,7 +43,7 @@ public class OverflowIO extends TsFileIOWriter {
}
public void clearRowGroupMetadatas() {
- super.chunkGroupMetaDataList.clear();
+ super.flushedChunkGroupMetaDataList.clear();
}
@Override
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowResource.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowResource.java
index e7167fb..39cc2ed 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowResource.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowResource.java
@@ -232,7 +232,7 @@ public class OverflowResource {
long lastPosition = insertIO.getPos();
// MemTableFlushUtil.flushMemTable(fileSchema, insertIO, memTable,
// versionController.nextVersion());
- MemTableFlushTask task = new MemTableFlushTask(insertIO, processorName);
+ MemTableFlushTask task = new MemTableFlushTask(insertIO, processorName, 0, (a,b)->{});
task.flushMemTable(fileSchema, memTable, versionController.nextVersion());
List<ChunkGroupMetaData> rowGroupMetaDatas = insertIO.getChunkGroupMetaDatas();
appendInsertMetadatas.addAll(rowGroupMetaDatas);