summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/sbe/stages/hash_join.cpp
diff options
context:
space:
mode:
authorAnton Korshunov <anton.korshunov@mongodb.com>2021-01-28 15:52:50 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-02-05 07:21:33 +0000
commit8fbc7b1b11a15625bc1025d2e30decb5ca2e48b3 (patch)
treebb0fdfba643c67e44592b68e62f6a7612750c49a /src/mongo/db/exec/sbe/stages/hash_join.cpp
parent2e376c871e15844736b285b8f68d003a7cf889d0 (diff)
downloadmongo-8fbc7b1b11a15625bc1025d2e30decb5ca2e48b3.tar.gz
SERVER-53271 Compute executionTimeMillisEstimates metric for SBE PlanStages
Diffstat (limited to 'src/mongo/db/exec/sbe/stages/hash_join.cpp')
-rw-r--r--src/mongo/db/exec/sbe/stages/hash_join.cpp6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/mongo/db/exec/sbe/stages/hash_join.cpp b/src/mongo/db/exec/sbe/stages/hash_join.cpp
index 8e5e167f743..e92bbebdab4 100644
--- a/src/mongo/db/exec/sbe/stages/hash_join.cpp
+++ b/src/mongo/db/exec/sbe/stages/hash_join.cpp
@@ -119,6 +119,8 @@ value::SlotAccessor* HashJoinStage::getAccessor(CompileCtx& ctx, value::SlotId s
}
void HashJoinStage::open(bool reOpen) {
+ auto optTimer(getOptTimer(_opCtx));
+
_commonStats.opens++;
_children[0]->open(reOpen);
// Insert the outer side into the hash table.
@@ -152,6 +154,8 @@ void HashJoinStage::open(bool reOpen) {
}
PlanState HashJoinStage::getNext() {
+ auto optTimer(getOptTimer(_opCtx));
+
if (_htIt != _htItEnd) {
++_htIt;
}
@@ -183,6 +187,8 @@ PlanState HashJoinStage::getNext() {
}
void HashJoinStage::close() {
+ auto optTimer(getOptTimer(_opCtx));
+
_commonStats.closes++;
_children[1]->close();
}