diff options
Diffstat (limited to 'src/mongo/db/pipeline/document_source_out.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/document_source_out.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/pipeline/document_source_out.cpp b/src/mongo/db/pipeline/document_source_out.cpp index 9be7c7a24ba..9b826fb3c89 100644 --- a/src/mongo/db/pipeline/document_source_out.cpp +++ b/src/mongo/db/pipeline/document_source_out.cpp @@ -177,6 +177,11 @@ void DocumentSourceOut::finalize() { _tempNs = {}; } +BatchedCommandRequest DocumentSourceOut::initializeBatchedWriteRequest() const { + // Note that our insert targets '_tempNs' since we will never write to 'outputNs' directly. + return DocumentSourceWriter::makeInsertCommand(_tempNs, pExpCtx->bypassDocumentValidation); +} + boost::intrusive_ptr<DocumentSource> DocumentSourceOut::create( NamespaceString outputNs, const boost::intrusive_ptr<ExpressionContext>& expCtx) { |