summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands
diff options
context:
space:
mode:
authorNick Zolnierz <nicholas.zolnierz@mongodb.com>2018-07-26 16:00:20 -0400
committerNick Zolnierz <nicholas.zolnierz@mongodb.com>2018-08-02 12:23:03 -0400
commitafbe688f0f18c5cb474fb1bcd933d6e06c0c5291 (patch)
treea7c1a3192f335c5e2947e395159eaa03782c3a50 /src/mongo/db/commands
parentafaf46687eb3930ddbfc8b528bd68295b6a09676 (diff)
downloadmongo-afbe688f0f18c5cb474fb1bcd933d6e06c0c5291.tar.gz
SERVER-35896: Support 'replaceDocuments' mode in $out
Diffstat (limited to 'src/mongo/db/commands')
-rw-r--r--src/mongo/db/commands/SConscript1
-rw-r--r--src/mongo/db/commands/run_aggregate.cpp3
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";