diff options
author | Nick Zolnierz <nicholas.zolnierz@mongodb.com> | 2018-07-26 16:00:20 -0400 |
---|---|---|
committer | Nick Zolnierz <nicholas.zolnierz@mongodb.com> | 2018-08-02 12:23:03 -0400 |
commit | afbe688f0f18c5cb474fb1bcd933d6e06c0c5291 (patch) | |
tree | a7c1a3192f335c5e2947e395159eaa03782c3a50 /src/mongo/db/commands | |
parent | afaf46687eb3930ddbfc8b528bd68295b6a09676 (diff) | |
download | mongo-afbe688f0f18c5cb474fb1bcd933d6e06c0c5291.tar.gz |
SERVER-35896: Support 'replaceDocuments' mode in $out
Diffstat (limited to 'src/mongo/db/commands')
-rw-r--r-- | src/mongo/db/commands/SConscript | 1 | ||||
-rw-r--r-- | src/mongo/db/commands/run_aggregate.cpp | 3 |
2 files changed, 3 insertions, 1 deletions
diff --git a/src/mongo/db/commands/SConscript b/src/mongo/db/commands/SConscript index 0c218665a46..6d391e461bf 100644 --- a/src/mongo/db/commands/SConscript +++ b/src/mongo/db/commands/SConscript @@ -240,6 +240,7 @@ env.Library( '$BUILD_DIR/mongo/db/commands', '$BUILD_DIR/mongo/db/curop_failpoint_helpers', '$BUILD_DIR/mongo/db/ops/write_ops_exec', + '$BUILD_DIR/mongo/db/pipeline/mongod_process_interface', '$BUILD_DIR/mongo/db/query_exec', '$BUILD_DIR/mongo/db/repair_database', '$BUILD_DIR/mongo/db/rw_concern_d', diff --git a/src/mongo/db/commands/run_aggregate.cpp b/src/mongo/db/commands/run_aggregate.cpp index 60efa126c3c..3fa7c3ffa93 100644 --- a/src/mongo/db/commands/run_aggregate.cpp +++ b/src/mongo/db/commands/run_aggregate.cpp @@ -49,6 +49,7 @@ #include "mongo/db/pipeline/expression.h" #include "mongo/db/pipeline/expression_context.h" #include "mongo/db/pipeline/lite_parsed_pipeline.h" +#include "mongo/db/pipeline/mongod_process_interface.h" #include "mongo/db/pipeline/pipeline.h" #include "mongo/db/pipeline/pipeline_d.h" #include "mongo/db/query/collation/collator_factory_interface.h" @@ -490,7 +491,7 @@ Status runAggregate(OperationContext* opCtx, new ExpressionContext(opCtx, request, std::move(*collatorToUse), - std::make_shared<PipelineD::MongoDInterface>(opCtx), + std::make_shared<MongoDInterface>(opCtx), uassertStatusOK(resolveInvolvedNamespaces(opCtx, request)), uuid)); expCtx->tempDir = storageGlobalParams.dbpath + "/_tmp"; |