diff options
Diffstat (limited to 'src/mongo/s/query/cluster_aggregation_planner.h')
-rw-r--r-- | src/mongo/s/query/cluster_aggregation_planner.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/s/query/cluster_aggregation_planner.h b/src/mongo/s/query/cluster_aggregation_planner.h index 75baded9e31..3b8b70fcd1d 100644 --- a/src/mongo/s/query/cluster_aggregation_planner.h +++ b/src/mongo/s/query/cluster_aggregation_planner.h @@ -81,12 +81,12 @@ SplitPipeline splitPipeline(std::unique_ptr<Pipeline, PipelineDeleter> pipeline) * front of 'mergePipeline'. */ void addMergeCursorsSource(Pipeline* mergePipeline, - const LiteParsedPipeline&, BSONObj cmdSentToShards, - std::vector<OwnedRemoteCursor> remoteCursors, + std::vector<OwnedRemoteCursor> ownedCursors, const std::vector<ShardId>& targetedShards, boost::optional<BSONObj> shardCursorsSortSpec, - std::shared_ptr<executor::TaskExecutor> executor); + std::shared_ptr<executor::TaskExecutor> executor, + bool hasChangeStream); /** * Builds a ClusterClientCursor which will execute 'pipeline'. If 'pipeline' consists entirely of |