summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/sbe_cmd.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/exec/sbe_cmd.cpp')
-rw-r--r--src/mongo/db/exec/sbe_cmd.cpp20
1 files changed, 9 insertions, 11 deletions
diff --git a/src/mongo/db/exec/sbe_cmd.cpp b/src/mongo/db/exec/sbe_cmd.cpp
index d29988e7b1b..d88039b3d22 100644
--- a/src/mongo/db/exec/sbe_cmd.cpp
+++ b/src/mongo/db/exec/sbe_cmd.cpp
@@ -38,6 +38,7 @@
#include "mongo/db/query/cursor_request.h"
#include "mongo/db/query/cursor_response.h"
#include "mongo/db/query/find_common.h"
+#include "mongo/db/query/plan_executor_factory.h"
namespace mongo {
/**
@@ -77,7 +78,7 @@ public:
NamespaceString nss{dbname};
- exec = uassertStatusOK(PlanExecutor::make(
+ exec = uassertStatusOK(plan_executor_factory::make(
opCtx,
nullptr,
{std::move(root), stage_builder::PlanStageData{resultSlot, recordIdSlot}},
@@ -110,16 +111,13 @@ public:
exec->detachFromOperationContext();
const auto pinnedCursor = CursorManager::get(opCtx)->registerCursor(
opCtx,
- {
- std::move(exec),
- nss,
- AuthorizationSession::get(opCtx->getClient())->getAuthenticatedUserNames(),
- opCtx->getWriteConcern(),
- repl::ReadConcernArgs::get(opCtx),
- cmdObj,
- {},
- false // needsMerge always 'false' for sbe.
- });
+ {std::move(exec),
+ nss,
+ AuthorizationSession::get(opCtx->getClient())->getAuthenticatedUserNames(),
+ opCtx->getWriteConcern(),
+ repl::ReadConcernArgs::get(opCtx),
+ cmdObj,
+ {}});
appendCursorResponseObject(
pinnedCursor.getCursor()->cursorid(), nss.ns(), firstBatch.arr(), &result);