choubenson commented on a change in pull request #4024:
URL: https://github.com/apache/iotdb/pull/4024#discussion_r720835994
##########
File path:
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
##########
@@ -171,18 +178,21 @@
private final TreeMap<Long, TsFileProcessor> workSequenceTsFileProcessors =
new TreeMap<>();
/** time partition id in the storage group -> tsFileProcessor for this time
partition */
private final TreeMap<Long, TsFileProcessor> workUnsequenceTsFileProcessors
= new TreeMap<>();
+
+ private final Deque<ByteBuffer> walByteBufferPool = new LinkedList<>();
/** compactionMergeWorking is used to wait for last compaction to be done. */
private volatile boolean compactionMergeWorking = false;
// upgrading sequence TsFile resource list
private List<TsFileResource> upgradeSeqFileList = new LinkedList<>();
-
/** sequence tsfile processors which are closing */
private CopyOnReadLinkedList<TsFileProcessor> closingSequenceTsFileProcessor
=
new CopyOnReadLinkedList<>();
-
// upgrading unsequence TsFile resource list
private List<TsFileResource> upgradeUnseqFileList = new LinkedList<>();
+ private Map<String, TsFileResource> settleSeqFileList = new HashMap<>();
+ private Map<String, TsFileResource> settleUnseqFileList = new HashMap<>();
Review comment:
It's to estimate whether the resource to be settled has been added in
the settleSeqFileMap.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
