summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/plan_executor_pipeline.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/plan_executor_pipeline.h')
-rw-r--r--src/mongo/db/pipeline/plan_executor_pipeline.h19
1 files changed, 14 insertions, 5 deletions
diff --git a/src/mongo/db/pipeline/plan_executor_pipeline.h b/src/mongo/db/pipeline/plan_executor_pipeline.h
index f6ad2a97341..54a66979bfc 100644
--- a/src/mongo/db/pipeline/plan_executor_pipeline.h
+++ b/src/mongo/db/pipeline/plan_executor_pipeline.h
@@ -46,10 +46,6 @@ public:
std::unique_ptr<Pipeline, PipelineDeleter> pipeline,
bool isChangeStream);
- PlanStage* getRootStage() const override {
- MONGO_UNREACHABLE;
- }
-
CanonicalQuery* getCanonicalQuery() const override {
return nullptr;
}
@@ -81,7 +77,20 @@ public:
bool isEOF() override;
- void executePlan() override;
+ // DocumentSource execution is only used for executing aggregation commands, so the interfaces
+ // for executing other CRUD operations are not supported.
+ long long executeCount() override {
+ MONGO_UNREACHABLE;
+ }
+ UpdateResult executeUpdate() override {
+ MONGO_UNREACHABLE;
+ }
+ UpdateResult getUpdateResult() const override {
+ MONGO_UNREACHABLE;
+ }
+ long long executeDelete() override {
+ MONGO_UNREACHABLE;
+ }
void dispose(OperationContext* opCtx) override {
_pipeline->dispose(opCtx);