diff options
author | Nicholas Zolnierz <nicholas.zolnierz@mongodb.com> | 2019-10-08 22:18:54 +0000 |
---|---|---|
committer | evergreen <evergreen@mongodb.com> | 2019-10-08 22:18:54 +0000 |
commit | 13c2e614e05cb58753ee3a89a0fa9b14d0837a6d (patch) | |
tree | 9f9ba57524e99c069a4a5e0db82f6490858e7cac /src/mongo/db/pipeline/mongos_process_interface.h | |
parent | 40fb24a73ce0c8c1092dda3f2631648990f4587a (diff) | |
download | mongo-13c2e614e05cb58753ee3a89a0fa9b14d0837a6d.tar.gz |
SERVER-42942 M/R Agg: Implement translation for cluster mapReduce command
Diffstat (limited to 'src/mongo/db/pipeline/mongos_process_interface.h')
-rw-r--r-- | src/mongo/db/pipeline/mongos_process_interface.h | 28 |
1 files changed, 0 insertions, 28 deletions
diff --git a/src/mongo/db/pipeline/mongos_process_interface.h b/src/mongo/db/pipeline/mongos_process_interface.h index 33e133adff2..fc6457fcc4b 100644 --- a/src/mongo/db/pipeline/mongos_process_interface.h +++ b/src/mongo/db/pipeline/mongos_process_interface.h @@ -45,34 +45,6 @@ namespace mongo { */ class MongoSInterface : public MongoProcessCommon { public: - static BSONObj createPassthroughCommandForShard(OperationContext* opCtx, - const AggregationRequest& request, - const boost::optional<ShardId>& shardId, - Pipeline* pipeline, - BSONObj collationObj); - - /** - * Appends information to the command sent to the shards which should be appended both if this - * is a passthrough sent to a single shard and if this is a split pipeline. - */ - static BSONObj genericTransformForShards(MutableDocument&& cmdForShards, - OperationContext* opCtx, - const boost::optional<ShardId>& shardId, - const AggregationRequest& request, - BSONObj collationObj); - - static BSONObj createCommandForTargetedShards( - OperationContext* opCtx, - const AggregationRequest& request, - const LiteParsedPipeline& litePipe, - const cluster_aggregation_planner::SplitPipeline& splitPipeline, - const BSONObj collationObj, - const boost::optional<cluster_aggregation_planner::ShardedExchangePolicy> exchangeSpec, - bool needsMerge); - - static StatusWith<CachedCollectionRoutingInfo> getExecutionNsRoutingInfo( - OperationContext* opCtx, const NamespaceString& execNss); - MongoSInterface() = default; virtual ~MongoSInterface() = default; |