summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_lookup.h
diff options
context:
space:
mode:
authorNick Zolnierz <nicholas.zolnierz@mongodb.com>2017-12-19 17:24:04 -0500
committerNick Zolnierz <nicholas.zolnierz@mongodb.com>2018-01-12 13:02:04 -0500
commit7298d273c0497f2720ec1471ad0f4910bff07af4 (patch)
tree09d37af52b38667db4f75b81d8203d8975e27848 /src/mongo/db/pipeline/document_source_lookup.h
parent5fe3df3c49c1f7b0906cc7650f3b339f22ddd0b5 (diff)
downloadmongo-7298d273c0497f2720ec1471ad0f4910bff07af4.tar.gz
SERVER-32308: Add the ability for a $lookup stage to execute on mongos against a sharded foreign collection
Diffstat (limited to 'src/mongo/db/pipeline/document_source_lookup.h')
-rw-r--r--src/mongo/db/pipeline/document_source_lookup.h20
1 files changed, 1 insertions, 19 deletions
diff --git a/src/mongo/db/pipeline/document_source_lookup.h b/src/mongo/db/pipeline/document_source_lookup.h
index 530c62f985c..7424b2ef97d 100644
--- a/src/mongo/db/pipeline/document_source_lookup.h
+++ b/src/mongo/db/pipeline/document_source_lookup.h
@@ -96,25 +96,7 @@ public:
*/
GetModPathsReturn getModifiedPaths() const final;
- StageConstraints constraints(Pipeline::SplitState pipeState) const final {
- const bool mayUseDisk = wasConstructedWithPipelineSyntax() &&
- std::any_of(_parsedIntrospectionPipeline->getSources().begin(),
- _parsedIntrospectionPipeline->getSources().end(),
- [](const auto& source) {
- return source->constraints().diskRequirement ==
- DiskUseRequirement::kWritesTmpData;
- });
-
- StageConstraints constraints(StreamType::kStreaming,
- PositionRequirement::kNone,
- HostTypeRequirement::kPrimaryShard,
- mayUseDisk ? DiskUseRequirement::kWritesTmpData
- : DiskUseRequirement::kNoDiskUse,
- FacetRequirement::kAllowed);
-
- constraints.canSwapWithMatch = true;
- return constraints;
- }
+ StageConstraints constraints(Pipeline::SplitState pipeState) const final;
GetDepsReturn getDependencies(DepsTracker* deps) const final;