diff options
| author | Bernard Gorman <bernard.gorman@gmail.com> | 2017-08-01 23:15:53 +0100 |
|---|---|---|
| committer | Bernard Gorman <bernard.gorman@gmail.com> | 2017-08-02 14:15:37 +0100 |
| commit | 27d43e300e292043fefd7634de99160157955a17 (patch) | |
| tree | 31844a3949fd1c900b3f7e93929faea1671b0c9b /src/mongo/db/exec | |
| parent | 20c85d4848b4e4b3c88e1788eaff362143fffd20 (diff) | |
| download | mongo-27d43e300e292043fefd7634de99160157955a17.tar.gz | |
SERVER-18940 Optimise sharded aggregations that are targeted to a single shard
Diffstat (limited to 'src/mongo/db/exec')
| -rw-r--r-- | src/mongo/db/exec/pipeline_proxy.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/mongo/db/exec/pipeline_proxy.cpp b/src/mongo/db/exec/pipeline_proxy.cpp index d6cbf80718b..4b291b59d89 100644 --- a/src/mongo/db/exec/pipeline_proxy.cpp +++ b/src/mongo/db/exec/pipeline_proxy.cpp @@ -51,7 +51,7 @@ PipelineProxyStage::PipelineProxyStage(OperationContext* opCtx, WorkingSet* ws) : PlanStage(kStageType, opCtx), _pipeline(std::move(pipeline)), - _includeMetaData(_pipeline->getContext()->inShard), // send metadata to merger + _includeMetaData(_pipeline->getContext()->needsMerge), // send metadata to merger _ws(ws) { // We take over responsibility for disposing of the Pipeline, since it is required that // doDispose() will be called before destruction of this PipelineProxyStage. |