diff options
| author | robot-piglet <robot-piglet@yandex-team.com> | 2024-01-31 16:51:44 +0300 |
|---|---|---|
| committer | robot-piglet <robot-piglet@yandex-team.com> | 2024-01-31 17:05:09 +0300 |
| commit | f04e74186f00a9665ef8442470f4b32cbf6bea17 (patch) | |
| tree | 61056a904cc17b57ea7f73263c81689f4df80a65 /yt | |
| parent | 43fcff14e5225f0019133c5643ebdf6d87c5de25 (diff) | |
| download | ydb-f04e74186f00a9665ef8442470f4b32cbf6bea17.tar.gz | |
Intermediate changes
Diffstat (limited to 'yt')
| -rw-r--r-- | yt/yt/client/api/queue_client.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/yt/yt/client/api/queue_client.h b/yt/yt/client/api/queue_client.h index 17849e0462..b6c6edeeac 100644 --- a/yt/yt/client/api/queue_client.h +++ b/yt/yt/client/api/queue_client.h @@ -92,6 +92,7 @@ struct IQueueClient //! Reads a batch of rows from a given partition of a given queue, starting at (at least) the given offset. //! Requires the user to have read-access to the specified queue. + //! There is no guarantee that `rowBatchReadOptions.MaxRowCount` rows will be returned even if they are in the queue. virtual TFuture<NQueueClient::IQueueRowsetPtr> PullQueue( const NYPath::TRichYPath& queuePath, i64 offset, @@ -100,6 +101,7 @@ struct IQueueClient const TPullQueueOptions& options = {}) = 0; //! Same as PullQueue, but requires user to have read-access to the consumer and the consumer being registered for the given queue. + //! There is no guarantee that `rowBatchReadOptions.MaxRowCount` rows will be returned even if they are in the queue. virtual TFuture<NQueueClient::IQueueRowsetPtr> PullConsumer( const NYPath::TRichYPath& consumerPath, const NYPath::TRichYPath& queuePath, |