diff options
author | Rui Liu <rui.liu@mongodb.com> | 2022-03-28 18:46:29 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-03-28 20:52:48 +0000 |
commit | fb7dec3b0825e561f2ea404f42c62e5116351dc1 (patch) | |
tree | 27ff09c9a1084a22041c3ff6c0f5f082a1a02c22 /src/mongo/db/pipeline/pipeline_d.cpp | |
parent | cf22bb8204da47c2d3696aabb2574077a66dcd66 (diff) | |
download | mongo-fb7dec3b0825e561f2ea404f42c62e5116351dc1.tar.gz |
SERVER-64662 Save secondary collection debugInfo for SBE foreign collections
Diffstat (limited to 'src/mongo/db/pipeline/pipeline_d.cpp')
-rw-r--r-- | src/mongo/db/pipeline/pipeline_d.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/mongo/db/pipeline/pipeline_d.cpp b/src/mongo/db/pipeline/pipeline_d.cpp index 1d6e05d358d..d40ff094c52 100644 --- a/src/mongo/db/pipeline/pipeline_d.cpp +++ b/src/mongo/db/pipeline/pipeline_d.cpp @@ -657,11 +657,11 @@ PipelineD::buildInnerQueryExecutorSample(DocumentSourceSample* sampleStage, ? DocumentSourceCursor::CursorType::kEmptyDocuments : DocumentSourceCursor::CursorType::kRegular; attachExecutorCallback = - [cursorType](const CollectionPtr& collection, + [cursorType](const MultipleCollectionAccessor& collections, std::unique_ptr<PlanExecutor, PlanExecutor::Deleter> exec, Pipeline* pipeline) { auto cursor = DocumentSourceCursor::create( - collection, std::move(exec), pipeline->getContext(), cursorType); + collections, std::move(exec), pipeline->getContext(), cursorType); pipeline->addInitialSource(std::move(cursor)); }; return std::pair(std::move(attachExecutorCallback), std::move(exec)); @@ -719,7 +719,7 @@ void PipelineD::attachInnerQueryExecutorToPipeline( // PlanExecutor provided in the 'attachExecutorCallback' object, so we don't need to do // anything. if (attachExecutorCallback && exec) { - attachExecutorCallback(collections.getMainCollection(), std::move(exec), pipeline); + attachExecutorCallback(collections, std::move(exec), pipeline); } } @@ -940,11 +940,11 @@ PipelineD::buildInnerQueryExecutorGeneric(const MultipleCollectionAccessor& coll (aggRequest && aggRequest->getRequestReshardingResumeToken()); auto attachExecutorCallback = - [cursorType, trackOplogTS](const CollectionPtr& collection, + [cursorType, trackOplogTS](const MultipleCollectionAccessor& collections, std::unique_ptr<PlanExecutor, PlanExecutor::Deleter> exec, Pipeline* pipeline) { auto cursor = DocumentSourceCursor::create( - collection, std::move(exec), pipeline->getContext(), cursorType, trackOplogTS); + collections, std::move(exec), pipeline->getContext(), cursorType, trackOplogTS); pipeline->addInitialSource(std::move(cursor)); }; return std::make_pair(std::move(attachExecutorCallback), std::move(exec)); @@ -997,10 +997,10 @@ PipelineD::buildInnerQueryExecutorGeoNear(const MultipleCollectionAccessor& coll locationField = geoNearStage->getLocationField(), distanceMultiplier = geoNearStage->getDistanceMultiplier().value_or(1.0)]( - const CollectionPtr& collection, + const MultipleCollectionAccessor& collections, std::unique_ptr<PlanExecutor, PlanExecutor::Deleter> exec, Pipeline* pipeline) { - auto cursor = DocumentSourceGeoNearCursor::create(collection, + auto cursor = DocumentSourceGeoNearCursor::create(collections, std::move(exec), pipeline->getContext(), distanceField, |