diff options
author | Nick Zolnierz <nicholas.zolnierz@mongodb.com> | 2017-12-19 17:24:04 -0500 |
---|---|---|
committer | Nick Zolnierz <nicholas.zolnierz@mongodb.com> | 2018-01-12 13:02:04 -0500 |
commit | 7298d273c0497f2720ec1471ad0f4910bff07af4 (patch) | |
tree | 09d37af52b38667db4f75b81d8203d8975e27848 /src/mongo/db/pipeline/document_source_lookup.h | |
parent | 5fe3df3c49c1f7b0906cc7650f3b339f22ddd0b5 (diff) | |
download | mongo-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.h | 20 |
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; |