diff options
| author | Pawel Terlecki <pawel.terlecki@mongodb.com> | 2019-06-14 17:56:57 -0400 |
|---|---|---|
| committer | Pawel Terlecki <pawel.terlecki@mongodb.com> | 2019-06-19 17:09:10 -0400 |
| commit | 5fac7b938d7a4ac41ec7ad2faa16350bfe6de41a (patch) | |
| tree | a4727f68b3c3ff43d459cd7450790b9c00873e10 /src/mongo/db/pipeline | |
| parent | 8217cf833cbc394bc9817fa7b3d00653284baf8a (diff) | |
| download | mongo-5fac7b938d7a4ac41ec7ad2faa16350bfe6de41a.tar.gz | |
SERVER-41701 [FLE] Add support for $bucket and $bucketAuto
Diffstat (limited to 'src/mongo/db/pipeline')
| -rw-r--r-- | src/mongo/db/pipeline/document_source_bucket_auto.cpp | 8 | ||||
| -rw-r--r-- | src/mongo/db/pipeline/document_source_bucket_auto.h | 3 |
2 files changed, 11 insertions, 0 deletions
diff --git a/src/mongo/db/pipeline/document_source_bucket_auto.cpp b/src/mongo/db/pipeline/document_source_bucket_auto.cpp index dbbf6c7b1f7..f8fa5e86ceb 100644 --- a/src/mongo/db/pipeline/document_source_bucket_auto.cpp +++ b/src/mongo/db/pipeline/document_source_bucket_auto.cpp @@ -438,6 +438,14 @@ DocumentSourceBucketAuto::DocumentSourceBucketAuto( } } +const boost::intrusive_ptr<Expression> DocumentSourceBucketAuto::getGroupByExpression() const { + return _groupByExpression; +} + +const std::vector<AccumulationStatement>& DocumentSourceBucketAuto::getAccumulatedFields() const { + return _accumulatedFields; +} + intrusive_ptr<DocumentSource> DocumentSourceBucketAuto::createFromBson( BSONElement elem, const intrusive_ptr<ExpressionContext>& pExpCtx) { uassert(40240, diff --git a/src/mongo/db/pipeline/document_source_bucket_auto.h b/src/mongo/db/pipeline/document_source_bucket_auto.h index bd0cc2483e8..ec2ff61b7e7 100644 --- a/src/mongo/db/pipeline/document_source_bucket_auto.h +++ b/src/mongo/db/pipeline/document_source_bucket_auto.h @@ -89,6 +89,9 @@ public: static boost::intrusive_ptr<DocumentSource> createFromBson( BSONElement elem, const boost::intrusive_ptr<ExpressionContext>& pExpCtx); + const boost::intrusive_ptr<Expression> getGroupByExpression() const; + const std::vector<AccumulationStatement>& getAccumulatedFields() const; + protected: void doDispose() final; |