quickstep-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hbdeshm...@apache.org
Subject [2/2] incubator-quickstep git commit: QueryContext::activateOperator called from QueryManager
Date Wed, 02 Nov 2016 04:00:30 GMT
QueryContext::activateOperator called from QueryManager

- QueryManagerSingleNode::activateOperator() calls
  QueryContext::activateOperator().


Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/fbecf5dd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/fbecf5dd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/fbecf5dd

Branch: refs/heads/delay-hashtable-memory-alloc
Commit: fbecf5ddea834323431467374b1729affd43d5a0
Parents: a11bff5
Author: Harshad Deshmukh <hbdeshmukh@apache.org>
Authored: Tue Nov 1 22:58:27 2016 -0500
Committer: Harshad Deshmukh <hbdeshmukh@apache.org>
Committed: Tue Nov 1 22:58:27 2016 -0500

----------------------------------------------------------------------
 query_execution/QueryManagerSingleNode.cpp | 9 +++++++++
 query_execution/QueryManagerSingleNode.hpp | 7 +------
 2 files changed, 10 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/fbecf5dd/query_execution/QueryManagerSingleNode.cpp
----------------------------------------------------------------------
diff --git a/query_execution/QueryManagerSingleNode.cpp b/query_execution/QueryManagerSingleNode.cpp
index 1b211a9..71097ab 100644
--- a/query_execution/QueryManagerSingleNode.cpp
+++ b/query_execution/QueryManagerSingleNode.cpp
@@ -241,4 +241,13 @@ void QueryManagerSingleNode::getRebuildWorkOrders(const dag_node_index
index,
   }
 }
 
+void QueryManagerSingleNode::activateOperator(const dag_node_index index) {
+  DCHECK(checkAllBlockingDependenciesMet(index));
+  // It is okay to call the line below multiple times.
+  query_dag_->getNodePayloadMutable(index)->informAllBlockingDependenciesMet();
+  query_context_->activateOperator(
+      query_handle()->getQueryContextProto(), index, storage_manager_);
+  processOperator(index, false);
+}
+
 }  // namespace quickstep

http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/fbecf5dd/query_execution/QueryManagerSingleNode.hpp
----------------------------------------------------------------------
diff --git a/query_execution/QueryManagerSingleNode.hpp b/query_execution/QueryManagerSingleNode.hpp
index 693684a..8e4a929 100644
--- a/query_execution/QueryManagerSingleNode.hpp
+++ b/query_execution/QueryManagerSingleNode.hpp
@@ -124,12 +124,7 @@ class QueryManagerSingleNode final : public QueryManagerBase {
   void getRebuildWorkOrders(const dag_node_index index,
                             WorkOrdersContainer *container);
 
-  void activateOperator(const dag_node_index index) {
-    DCHECK(checkAllBlockingDependenciesMet(index));
-    // It is okay to call the line below multiple times.
-    query_dag_->getNodePayloadMutable(index)->informAllBlockingDependenciesMet();
-    processOperator(index, false);
-  }
+  void activateOperator(const dag_node_index index);
 
   WorkerMessage *getNextWorkerMessageFromActiveOperators(
       const numa_node_id numa_node);


Mime
View raw message