summaryrefslogtreecommitdiff
path: root/src/mongo/s/query/cluster_aggregate.cpp
diff options
context:
space:
mode:
authorHana Pearlman <hana.pearlman@mongodb.com>2022-04-04 20:50:42 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-04-04 21:42:31 +0000
commit31c733015e41c04d903e6b807a699fbce84d22bb (patch)
treedd0670eac4661180f39f0b8924f89c1d7b1dfe7d /src/mongo/s/query/cluster_aggregate.cpp
parent006cef15212cf443794d9f62c31a031fc8d87fb5 (diff)
downloadmongo-31c733015e41c04d903e6b807a699fbce84d22bb.tar.gz
SERVER-63312: Implement FLE server-side rewrite for agg on mongod
Diffstat (limited to 'src/mongo/s/query/cluster_aggregate.cpp')
-rw-r--r--src/mongo/s/query/cluster_aggregate.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/s/query/cluster_aggregate.cpp b/src/mongo/s/query/cluster_aggregate.cpp
index 2034489bb49..4bcd150206b 100644
--- a/src/mongo/s/query/cluster_aggregate.cpp
+++ b/src/mongo/s/query/cluster_aggregate.cpp
@@ -365,10 +365,10 @@ Status ClusterAggregate::runAggregate(OperationContext* opCtx,
// support querying against encrypted fields.
if (shouldDoFLERewrite) {
// After this rewriting, the encryption info does not need to be kept around.
- pipeline = fle::processPipeline(opCtx,
- namespaces.executionNss,
- request.getEncryptionInformation().get(),
- std::move(pipeline));
+ pipeline = processFLEPipelineS(opCtx,
+ namespaces.executionNss,
+ request.getEncryptionInformation().get(),
+ std::move(pipeline));
request.setEncryptionInformation(boost::none);
}