diff options
Diffstat (limited to 'src/mongo/db/query/plan_executor_factory.h')
| -rw-r--r-- | src/mongo/db/query/plan_executor_factory.h | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/mongo/db/query/plan_executor_factory.h b/src/mongo/db/query/plan_executor_factory.h index 3d27507cfd2..8faad454285 100644 --- a/src/mongo/db/query/plan_executor_factory.h +++ b/src/mongo/db/query/plan_executor_factory.h @@ -33,6 +33,7 @@ #include "mongo/db/exec/sbe/stages/stages.h" #include "mongo/db/exec/working_set.h" +#include "mongo/db/pipeline/pipeline.h" #include "mongo/db/query/plan_executor.h" #include "mongo/db/query/plan_yield_policy_sbe.h" #include "mongo/db/query/query_solution.h" @@ -120,4 +121,12 @@ StatusWith<std::unique_ptr<PlanExecutor, PlanExecutor::Deleter>> make( std::queue<std::pair<BSONObj, boost::optional<RecordId>>> stash, std::unique_ptr<PlanYieldPolicySBE> yieldPolicy); +/** + * Constructs a plan executor for executing the given 'pipeline'. + */ +std::unique_ptr<PlanExecutor, PlanExecutor::Deleter> make( + boost::intrusive_ptr<ExpressionContext> expCtx, + std::unique_ptr<Pipeline, PipelineDeleter> pipeline, + bool isChangeStream); + } // namespace mongo::plan_executor_factory |