1 files changed, 2 insertions, 10 deletions
diff --git a/src/mongo/db/pipeline/document_source_out.cpp b/src/mongo/db/pipeline/document_source_out.cpp
index a6188dfd382..9be7c7a24ba 100644
--- a/src/mongo/db/pipeline/document_source_out.cpp
+++ b/src/mongo/db/pipeline/document_source_out.cpp
@@ -177,11 +177,6 @@ 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) {
 
@@ -210,11 +205,8 @@ boost::intrusive_ptr<DocumentSource> DocumentSourceOut::createFromBson(
     return create(targetNS, expCtx);
 }
 
-Value DocumentSourceOut::serialize(const SerializationOptions& opts) const {
-    MutableDocument spec;
-    spec["coll"] = Value(opts.serializeIdentifier(_outputNs.coll()));
-    spec["db"] = Value(opts.serializeIdentifier(_outputNs.db()));
-    return Value(Document{{kStageName, spec.freezeToValue()}});
+Value DocumentSourceOut::serialize(boost::optional<ExplainOptions::Verbosity> explain) const {
+    return Value(DOC(kStageName << DOC("db" << _outputNs.db() << "coll" << _outputNs.coll())));
 }
 
 void DocumentSourceOut::waitWhileFailPointEnabled() {