JackieTien97 commented on a change in pull request #4534:
URL: https://github.com/apache/iotdb/pull/4534#discussion_r763875021
##########
File path:
server/src/main/java/org/apache/iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java
##########
@@ -530,6 +560,10 @@ protected void fillCache(int seriesIndex) throws
IOException, InterruptedExcepti
synchronized (seriesReaderList.get(seriesIndex)) {
// we only need to judge whether to submit another task when the queue
is not full
if (blockingQueueArray[seriesIndex].remainingCapacity() > 0) {
+ if (batchDataLengthList != null
+ && batchDataLengthList.get(seriesIndex) >= rowLimit + rowOffset)
{
+ return;
+ }
Review comment:
You can safely delete this `if` block. It seems that we don't need to do
this judgement here, because we will set `hasRemaining` to false in sub thread.
##########
File path:
server/src/main/java/org/apache/iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java
##########
@@ -58,12 +58,23 @@
private final ManagedSeriesReader reader;
private final String pathName;
private final BlockingQueue<BatchData> blockingQueue;
+ private List<Integer> batchDataLengthList;
Review comment:
use `int[]` instead of `List<Integer>`
--
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]
