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;
   }

Reply via email to