summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_internal_unpack_bucket.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_internal_unpack_bucket.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_internal_unpack_bucket.cpp7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/pipeline/document_source_internal_unpack_bucket.cpp b/src/mongo/db/pipeline/document_source_internal_unpack_bucket.cpp
index a950aeee4f4..9ef6d892a51 100644
--- a/src/mongo/db/pipeline/document_source_internal_unpack_bucket.cpp
+++ b/src/mongo/db/pipeline/document_source_internal_unpack_bucket.cpp
@@ -246,6 +246,7 @@ DocumentSourceInternalUnpackBucket::DocumentSourceInternalUnpackBucket(
bool assumeNoMixedSchemaData)
: DocumentSource(kStageNameInternal, expCtx),
_assumeNoMixedSchemaData(assumeNoMixedSchemaData),
+
_bucketUnpacker(std::move(bucketUnpacker)),
_bucketMaxSpanSeconds{bucketMaxSpanSeconds} {}
@@ -353,6 +354,12 @@ boost::intrusive_ptr<DocumentSource> DocumentSourceInternalUnpackBucket::createF
<< " field must be a bool, got: " << elem.type(),
elem.type() == BSONType::Bool);
bucketSpec.includeMaxTimeAsMetadata = elem.boolean();
+ } else if (fieldName == kUsesExtendedRange) {
+ uassert(6646901,
+ str::stream() << kUsesExtendedRange
+ << " field must be a bool, got: " << elem.type(),
+ elem.type() == BSONType::Bool);
+ bucketSpec.setUsesExtendedRange(elem.boolean());
} else {
uasserted(5346506,
str::stream()