shizy818 commented on code in PR #14616:
URL: https://github.com/apache/iotdb/pull/14616#discussion_r1909649333
##########
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/utils/ResourceByPathUtils.java:
##########
@@ -419,4 +531,107 @@ public List<IChunkMetadata>
getVisibleMetadataListFromWriter(
chunkMetadataList.removeIf(x -> x.getEndTime() < timeLowerBound);
return chunkMetadataList;
}
+
+ /**
+ * Prepare the TVList references for the query. We remember TVLists' row
count here and determine
+ * whether the TVLists needs sorting later during operator execution based
on it. It need not
+ * protect sorted list. Sorted list is changed in the handover process of
inserting, which holds
+ * the data region write lock. At this moment, query thread holds the data
region read lock.
+ *
+ * @param context query context
+ * @param memChunk writable memchunk
+ * @param isWorkMemTable in working or flushing memtable
+ * @param globalTimeFilter global time filter
+ * @return Map<TVList, Integer>
+ */
+ private Map<TVList, Integer> prepareTvListMapForQuery(
Review Comment:
I used to try abstracting them and have some generic type issue. Anyway now
I have more time to have a try.
--
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]
