Skip to content

Commit 53d7364

Browse files
committed
fix
1 parent bb3ef1d commit 53d7364

5 files changed

Lines changed: 4 additions & 6 deletions

File tree

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/IDIndexedAccessible.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,6 @@
1919

2020
package org.apache.iotdb.calc.execution.schedule.queue;
2121

22-
import org.apache.iotdb.db.queryengine.execution.schedule.queue.IndexedBlockingQueue;
23-
2422
/**
2523
* A simple interface for id getter and setter.
2624
*

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/IndexedBlockingQueue.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ public final synchronized int size() {
166166
*
167167
* @return true if the queue is empty, otherwise false.
168168
*/
169-
protected abstract boolean isEmpty();
169+
public abstract boolean isEmpty();
170170

171171
/**
172172
* Get and remove the first element.

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/L1PriorityQueue.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public L1PriorityQueue(int maxCapacity, Comparator<E> comparator, E queryHolder)
6262
}
6363

6464
@Override
65-
protected boolean isEmpty() {
65+
public boolean isEmpty() {
6666
return keyedElements.isEmpty();
6767
}
6868

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/L2PriorityQueue.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ public L2PriorityQueue(int maxCapacity, Comparator<E> comparator, E queryHolder)
7070
}
7171

7272
@Override
73-
protected boolean isEmpty() {
73+
public boolean isEmpty() {
7474
return workingKeyedElements.isEmpty() && idleKeyedElements.isEmpty();
7575
}
7676

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/multilevelqueue/MultilevelPriorityQueue.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ protected DriverTask remove(DriverTask driverTask) {
158158
}
159159

160160
@Override
161-
protected boolean isEmpty() {
161+
public boolean isEmpty() {
162162
if (!highestPriorityLevelQueue.isEmpty()) {
163163
return false;
164164
}

0 commit comments

Comments
 (0)