diff options
author | David Storch <david.storch@mongodb.com> | 2020-07-09 20:07:55 -0400 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-07-24 16:31:37 +0000 |
commit | b4b35f9cc69412611a198642333bf40daa5ba58c (patch) | |
tree | 909673b812a499a60692c46abb53853f7df42b48 /src/mongo/db/query/plan_executor_factory.h | |
parent | 5e53ee3ca0a90eb98cdab94b298dec810fb46804 (diff) | |
download | mongo-b4b35f9cc69412611a198642333bf40daa5ba58c.tar.gz |
SERVER-48478 Replace PipelineProxyStage with PlanExecutorPipeline
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 |