diff options
author | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-11-29 17:39:33 -0500 |
---|---|---|
committer | Charlie Swanson <charlie.swanson@mongodb.com> | 2019-01-16 10:09:59 -0500 |
commit | 0cb2195939494660334db8e9d0a52509caeb621c (patch) | |
tree | 2d71e10270020f2e7ea8bf3bfb812b13f83abbca /src/mongo/db/pipeline/document_source_group.h | |
parent | d29f140ae0e69057d8b1801f4d2a993612fa5bcb (diff) | |
download | mongo-0cb2195939494660334db8e9d0a52509caeb621c.tar.gz |
SERVER-38311 Adjust $out merging strategy
Diffstat (limited to 'src/mongo/db/pipeline/document_source_group.h')
-rw-r--r-- | src/mongo/db/pipeline/document_source_group.h | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/mongo/db/pipeline/document_source_group.h b/src/mongo/db/pipeline/document_source_group.h index a1d6fdad059..6348a83ab46 100644 --- a/src/mongo/db/pipeline/document_source_group.h +++ b/src/mongo/db/pipeline/document_source_group.h @@ -87,7 +87,7 @@ private: std::string _groupId; }; -class DocumentSourceGroup final : public DocumentSource, public NeedsMergerDocumentSource { +class DocumentSourceGroup final : public DocumentSource { public: using Accumulators = std::vector<boost::intrusive_ptr<Accumulator>>; using GroupsMap = ValueUnorderedMap<Accumulators>; @@ -162,9 +162,7 @@ public: */ bool usedDisk() final; - // Virtuals for NeedsMergerDocumentSource. - boost::intrusive_ptr<DocumentSource> getShardSource() final; - MergingLogic mergingLogic() final; + boost::optional<MergingLogic> mergingLogic() final; bool canRunInParallelBeforeOut( const std::set<std::string>& nameOfShardKeyFieldsUponEntryToStage) const final; |