diff options
| author | Bernard Gorman <bernard.gorman@gmail.com> | 2018-11-27 03:50:42 +0000 |
|---|---|---|
| committer | Bernard Gorman <bernard.gorman@gmail.com> | 2019-01-09 07:16:40 +0000 |
| commit | 560a0c3a3e20924b362fc2b159c30255d62e81d2 (patch) | |
| tree | 18a082ebad4c1e50f988025e8a53036836175400 /src/mongo/s/query/document_source_merge_cursors.h | |
| parent | ec104311f774165b5b77b41b78c89e4f29baaca9 (diff) | |
| download | mongo-560a0c3a3e20924b362fc2b159c30255d62e81d2.tar.gz | |
SERVER-38411 Propagate postBatchResumeToken through mongoS to client
Diffstat (limited to 'src/mongo/s/query/document_source_merge_cursors.h')
| -rw-r--r-- | src/mongo/s/query/document_source_merge_cursors.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/s/query/document_source_merge_cursors.h b/src/mongo/s/query/document_source_merge_cursors.h index 5249da51a8e..f733d2c3088 100644 --- a/src/mongo/s/query/document_source_merge_cursors.h +++ b/src/mongo/s/query/document_source_merge_cursors.h @@ -99,6 +99,13 @@ public: std::size_t getNumRemotes() const; + /** + * Returns the high water mark sort key for the given cursor, if it exists; otherwise, returns + * an empty BSONObj. Calling this method causes the underlying BlockingResultsMerger to be + * populated and assumes ownership of the remote cursors. + */ + BSONObj getHighWaterMark(); + bool remotesExhausted() const; void setExecContext(RouterExecStage::ExecContext execContext) { |