diff options
| author | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-11-07 10:02:30 -0500 |
|---|---|---|
| committer | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-11-16 15:22:28 -0500 |
| commit | 4a74a41fc5d2014aad3a2b85630f8e2e51156d51 (patch) | |
| tree | a23f64403366d7963e5c1e37b63e149c46912b65 /src/mongo/db/pipeline/document_source_change_stream_transform.cpp | |
| parent | 410656e971aff8f491a87337a17d04bd866389ba (diff) | |
| download | mongo-4a74a41fc5d2014aad3a2b85630f8e2e51156d51.tar.gz | |
SERVER-37982 Distinguish use cases for collecting document key fields
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream_transform.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/document_source_change_stream_transform.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream_transform.cpp b/src/mongo/db/pipeline/document_source_change_stream_transform.cpp index 8a94978ef15..db600fb9e5b 100644 --- a/src/mongo/db/pipeline/document_source_change_stream_transform.cpp +++ b/src/mongo/db/pipeline/document_source_change_stream_transform.cpp @@ -229,8 +229,9 @@ Document DocumentSourceChangeStreamTransform::applyTransformation(const Document // unsharded when the entry was last populated. auto it = _documentKeyCache.find(uuid.getUuid()); if (it == _documentKeyCache.end() || !it->second.isFinal) { - auto docKeyFields = pExpCtx->mongoProcessInterface->collectDocumentKeyFields( - pExpCtx->opCtx, NamespaceStringOrUUID(nss.db().toString(), uuid.getUuid())); + auto docKeyFields = + pExpCtx->mongoProcessInterface->collectDocumentKeyFieldsForHostedCollection( + pExpCtx->opCtx, nss, uuid.getUuid()); if (it == _documentKeyCache.end() || docKeyFields.second) { _documentKeyCache[uuid.getUuid()] = DocumentKeyCacheEntry(docKeyFields); } |