summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/pipeline_d.cpp
diff options
context:
space:
mode:
authorRui Liu <rui.liu@mongodb.com>2022-03-28 18:46:29 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-03-28 20:52:48 +0000
commitfb7dec3b0825e561f2ea404f42c62e5116351dc1 (patch)
tree27ff09c9a1084a22041c3ff6c0f5f082a1a02c22 /src/mongo/db/pipeline/pipeline_d.cpp
parentcf22bb8204da47c2d3696aabb2574077a66dcd66 (diff)
downloadmongo-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.cpp14
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,