summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_group.h
diff options
context:
space:
mode:
authorCharlie Swanson <charlie.swanson@mongodb.com>2018-11-29 17:39:33 -0500
committerCharlie Swanson <charlie.swanson@mongodb.com>2019-01-16 10:09:59 -0500
commit0cb2195939494660334db8e9d0a52509caeb621c (patch)
tree2d71e10270020f2e7ea8bf3bfb812b13f83abbca /src/mongo/db/pipeline/document_source_group.h
parentd29f140ae0e69057d8b1801f4d2a993612fa5bcb (diff)
downloadmongo-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.h6
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;