summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/pipeline.h
diff options
context:
space:
mode:
authorBernard Gorman <bernard.gorman@gmail.com>2017-11-06 12:38:36 +0000
committerBernard Gorman <bernard.gorman@gmail.com>2017-11-09 20:55:21 +0000
commit862958d49fc7c19d2d74a5e1ad25c3a5c4a4cd16 (patch)
tree3e7ffeafd8fbad9c8b5da824f80b8df0af6b08f1 /src/mongo/db/pipeline/pipeline.h
parentefe2d334dca9ab5fbf0181f3f761b8af5a43dd47 (diff)
downloadmongo-862958d49fc7c19d2d74a5e1ad25c3a5c4a4cd16.tar.gz
SERVER-31763 $changeStream on sharded collections must always split on mongoS even if targeting a single shard
Diffstat (limited to 'src/mongo/db/pipeline/pipeline.h')
-rw-r--r--src/mongo/db/pipeline/pipeline.h7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/mongo/db/pipeline/pipeline.h b/src/mongo/db/pipeline/pipeline.h
index de7cda54c7d..6697848fde3 100644
--- a/src/mongo/db/pipeline/pipeline.h
+++ b/src/mongo/db/pipeline/pipeline.h
@@ -238,11 +238,16 @@ public:
BSONObj getInitialQuery() const;
/**
- * Returns whether or not any DocumentSource in the pipeline needs the primary shard.
+ * Returns 'true' if the pipeline must merge on the primary shard.
*/
bool needsPrimaryShardMerger() const;
/**
+ * Returns 'true' if the pipeline must merge on mongoS.
+ */
+ bool needsMongosMerger() const;
+
+ /**
* Returns true if the pipeline can run on mongoS, but is not obliged to; that is, it can run
* either on mongoS or on a shard.
*/