diff options
| author | Xin Hao Zhang <xinhao.zhang@mongodb.com> | 2019-07-23 11:35:07 -0400 |
|---|---|---|
| committer | Xin Hao Zhang <xinhao.zhang@mongodb.com> | 2019-07-24 08:09:43 -0400 |
| commit | 5c9f7fb5d38df176bda950bdea6aaadbcb73e8e1 (patch) | |
| tree | efbde299324ff4b5f1e132c64b5ea00918cf8ecd /src/mongo/db/pipeline/pipeline_d.cpp | |
| parent | 093b5bf0d87d3415e32af22ce8a7f19a47f64929 (diff) | |
| download | mongo-5c9f7fb5d38df176bda950bdea6aaadbcb73e8e1.tar.gz | |
SERVER-36186 Default to the the oplogreplay optimization path for oplog collections
Diffstat (limited to 'src/mongo/db/pipeline/pipeline_d.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/pipeline_d.cpp | 12 |
1 files changed, 0 insertions, 12 deletions
diff --git a/src/mongo/db/pipeline/pipeline_d.cpp b/src/mongo/db/pipeline/pipeline_d.cpp index d6e3557bcd9..f133a67c9bc 100644 --- a/src/mongo/db/pipeline/pipeline_d.cpp +++ b/src/mongo/db/pipeline/pipeline_d.cpp @@ -168,7 +168,6 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> attemptToGetExe Collection* collection, const NamespaceString& nss, const intrusive_ptr<ExpressionContext>& pExpCtx, - bool oplogReplay, BSONObj queryObj, BSONObj projectionObj, BSONObj sortObj, @@ -178,7 +177,6 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> attemptToGetExe const MatchExpressionParser::AllowedFeatureSet& matcherFeatures) { auto qr = std::make_unique<QueryRequest>(nss); qr->setTailableMode(pExpCtx->tailableMode); - qr->setOplogReplay(oplogReplay); qr->setFilter(queryObj); qr->setProj(projectionObj); qr->setSort(sortObj); @@ -442,12 +440,10 @@ PipelineD::buildInnerQueryExecutorGeneric(Collection* collection, // Look for an initial match. This works whether we got an initial query or not. If not, it // results in a "{}" query, which will be what we want in that case. - bool oplogReplay = false; const BSONObj queryObj = pipeline->getInitialQuery(); if (!queryObj.isEmpty()) { auto matchStage = dynamic_cast<DocumentSourceMatch*>(sources.front().get()); if (matchStage) { - oplogReplay = dynamic_cast<DocumentSourceOplogMatch*>(matchStage) != nullptr; // If a $match query is pulled into the cursor, the $match is redundant, and can be // removed from the pipeline. sources.pop_front(); @@ -487,7 +483,6 @@ PipelineD::buildInnerQueryExecutorGeneric(Collection* collection, nss, pipeline, expCtx, - oplogReplay, sortStage, std::move(rewrittenGroupStage), deps, @@ -558,7 +553,6 @@ PipelineD::buildInnerQueryExecutorGeoNear(Collection* collection, nss, pipeline, expCtx, - false, /* oplogReplay */ nullptr, /* sortStage */ nullptr, /* rewrittenGroupStage */ deps, @@ -600,7 +594,6 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> PipelineD::prep const NamespaceString& nss, Pipeline* pipeline, const intrusive_ptr<ExpressionContext>& expCtx, - bool oplogReplay, const boost::intrusive_ptr<DocumentSourceSort>& sortStage, std::unique_ptr<GroupFromFirstDocumentTransformation> rewrittenGroupStage, const DepsTracker& deps, @@ -652,7 +645,6 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> PipelineD::prep collection, nss, expCtx, - oplogReplay, queryObj, *projectionObj, sortObj ? *sortObj : emptySort, @@ -708,7 +700,6 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> PipelineD::prep collection, nss, expCtx, - oplogReplay, queryObj, expCtx->needsMerge ? metaSortProjection : emptyProjection, *sortObj, @@ -724,7 +715,6 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> PipelineD::prep collection, nss, expCtx, - oplogReplay, queryObj, *projectionObj, *sortObj, @@ -787,7 +777,6 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> PipelineD::prep collection, nss, expCtx, - oplogReplay, queryObj, *projectionObj, *sortObj, @@ -812,7 +801,6 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> PipelineD::prep collection, nss, expCtx, - oplogReplay, queryObj, *projectionObj, *sortObj, |