summaryrefslogtreecommitdiff
path: root/src/mongo/s/query/cluster_client_cursor_params.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/s/query/cluster_client_cursor_params.h')
-rw-r--r--src/mongo/s/query/cluster_client_cursor_params.h4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/s/query/cluster_client_cursor_params.h b/src/mongo/s/query/cluster_client_cursor_params.h
index 7507ad82ae8..1b4d76124c3 100644
--- a/src/mongo/s/query/cluster_client_cursor_params.h
+++ b/src/mongo/s/query/cluster_client_cursor_params.h
@@ -37,6 +37,7 @@
#include "mongo/db/auth/user_name.h"
#include "mongo/db/cursor_id.h"
#include "mongo/db/namespace_string.h"
+#include "mongo/db/pipeline/pipeline.h"
#include "mongo/db/query/cursor_response.h"
#include "mongo/s/client/shard.h"
#include "mongo/util/net/hostandport.h"
@@ -110,6 +111,9 @@ struct ClusterClientCursorParams {
// Should be forwarded to the remote hosts in 'cmdObj'.
boost::optional<long long> limit;
+ // If set, we use this pipeline to merge the output of aggregations on each remote.
+ std::unique_ptr<Pipeline, Pipeline::Deleter> mergePipeline;
+
// Whether this cursor is tailing a capped collection.
bool isTailable = false;