From a1c98bc8c9730a199c15da198198ccceef39d74f Mon Sep 17 00:00:00 2001 From: pufit Date: Wed, 20 Sep 2023 09:50:35 -0400 Subject: [PATCH] fix build --- src/Storages/S3Queue/S3QueueSource.cpp | 5 +++++ src/Storages/S3Queue/S3QueueSource.h | 2 ++ 2 files changed, 7 insertions(+) diff --git a/src/Storages/S3Queue/S3QueueSource.cpp b/src/Storages/S3Queue/S3QueueSource.cpp index 54a863aeb2c..5f640239985 100644 --- a/src/Storages/S3Queue/S3QueueSource.cpp +++ b/src/Storages/S3Queue/S3QueueSource.cpp @@ -147,6 +147,11 @@ StorageS3QueueSource::KeyWithInfo StorageS3QueueSource::QueueGlobIterator::next( return KeyWithInfo(); } +size_t StorageS3QueueSource::QueueGlobIterator::estimatedKeysCount() +{ + return keys_buf.size(); +} + StorageS3QueueSource::StorageS3QueueSource( const ReadFromFormatInfo & info, const String & format_, diff --git a/src/Storages/S3Queue/S3QueueSource.h b/src/Storages/S3Queue/S3QueueSource.h index f89384fb096..0f83ed054d5 100644 --- a/src/Storages/S3Queue/S3QueueSource.h +++ b/src/Storages/S3Queue/S3QueueSource.h @@ -54,6 +54,8 @@ public: Strings filterProcessingFiles(const S3QueueMode & engine_mode, std::unordered_set & exclude_keys, const String & max_file = ""); + size_t estimatedKeysCount() override; + private: UInt64 max_poll_size; KeysWithInfo keys_buf;