diff options
Diffstat (limited to 'src/mongo/db/exec/sbe_cmd.cpp')
-rw-r--r-- | src/mongo/db/exec/sbe_cmd.cpp | 20 |
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); |