You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/02/17 03:51:16 UTC
[incubator-iotdb] branch master updated: [IOTDB-491] Constant name
`pool ` should be all uppercase (#813)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new e502f5d [IOTDB-491] Constant name `pool ` should be all uppercase (#813)
e502f5d is described below
commit e502f5d9ade8401036e541b6cfc70314960773c3
Author: Xin Wang <xi...@apache.org>
AuthorDate: Mon Feb 17 11:51:06 2020 +0800
[IOTDB-491] Constant name `pool ` should be all uppercase (#813)
---
.../db/query/dataset/NewEngineDataSetWithoutValueFilter.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/query/dataset/NewEngineDataSetWithoutValueFilter.java b/server/src/main/java/org/apache/iotdb/db/query/dataset/NewEngineDataSetWithoutValueFilter.java
index 3208378..2dcaf77 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/dataset/NewEngineDataSetWithoutValueFilter.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/dataset/NewEngineDataSetWithoutValueFilter.java
@@ -69,7 +69,7 @@ public class NewEngineDataSetWithoutValueFilter extends QueryDataSet {
blockingQueue.put(batchData);
// if the queue also has free space, just submit another itself
if (blockingQueue.remainingCapacity() > 0) {
- pool.submit(this);
+ TASK_POOL_MANAGER.submit(this);
}
// the queue has no more space
// remove itself from the QueryTaskPoolManager
@@ -119,7 +119,7 @@ public class NewEngineDataSetWithoutValueFilter extends QueryDataSet {
// capacity for blocking queue
private static final int BLOCKING_QUEUE_CAPACITY = 5;
- private static final QueryTaskPoolManager pool = QueryTaskPoolManager.getInstance();
+ private static final QueryTaskPoolManager TASK_POOL_MANAGER = QueryTaskPoolManager.getInstance();
private static final Logger LOGGER = LoggerFactory.getLogger(NewEngineDataSetWithoutValueFilter.class);
@@ -150,7 +150,7 @@ public class NewEngineDataSetWithoutValueFilter extends QueryDataSet {
ManagedSeriesReader reader = seriesReaderWithoutValueFilterList.get(i);
reader.setHasRemaining(true);
reader.setManagedByQueryManager(true);
- pool.submit(new ReadTask(reader, blockingQueueArray[i]));
+ TASK_POOL_MANAGER.submit(new ReadTask(reader, blockingQueueArray[i]));
}
for (int i = 0; i < seriesReaderWithoutValueFilterList.size(); i++) {
fillCache(i);
@@ -349,7 +349,7 @@ public class NewEngineDataSetWithoutValueFilter extends QueryDataSet {
// now we should submit it again
if (!reader.isManagedByQueryManager() && reader.hasRemaining()) {
reader.setManagedByQueryManager(true);
- pool.submit(new ReadTask(reader, blockingQueueArray[seriesIndex]));
+ TASK_POOL_MANAGER.submit(new ReadTask(reader, blockingQueueArray[seriesIndex]));
}
}
}