This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch MasterQueryDebug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/MasterQueryDebug by this push:
new 54b5f27 Explain Query Support
54b5f27 is described below
commit 54b5f27a2d951c25383d9ffc219a8ec8f9923566
Author: JackieTien97 <[email protected]>
AuthorDate: Mon Mar 15 18:28:02 2021 +0800
Explain Query Support
---
.../main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java | 4 ++++
.../src/main/java/org/apache/iotdb/cluster/server/ClientServer.java | 4 ++--
2 files changed, 6 insertions(+), 2 deletions(-)
diff --git
a/cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java
b/cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java
index d3164f3..1ecf758 100644
---
a/cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java
+++
b/cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java
@@ -41,6 +41,10 @@ public class RemoteQueryContext extends QueryContext {
super(jobId);
}
+ public RemoteQueryContext(long jobId, boolean debug) {
+ super(jobId, debug);
+ }
+
public void registerRemoteNode(Node node, Node header) {
queriedNodesMap.computeIfAbsent(header, n -> new HashSet<>()).add(node);
}
diff --git
a/cluster/src/main/java/org/apache/iotdb/cluster/server/ClientServer.java
b/cluster/src/main/java/org/apache/iotdb/cluster/server/ClientServer.java
index 29fc3f8..3ae9418 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/ClientServer.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/ClientServer.java
@@ -281,8 +281,8 @@ public class ClientServer extends TSServiceImpl {
* @return a RemoteQueryContext using queryId
*/
@Override
- protected QueryContext genQueryContext(long queryId) {
- RemoteQueryContext context = new RemoteQueryContext(queryId);
+ protected QueryContext genQueryContext(long queryId, boolean debug) {
+ RemoteQueryContext context = new RemoteQueryContext(queryId, debug);
queryContextMap.put(queryId, context);
return context;
}