thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 00:30:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix build

Browse Source
This commit is contained in:
pufit 2023-09-20 09:50:35 -04:00
parent 34aecc0bf3
commit a1c98bc8c9
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Storages/S3Queue/S3QueueSource.cpp
View File

@ -147,6 +147,11 @@ StorageS3QueueSource::KeyWithInfo StorageS3QueueSource::QueueGlobIterator::next(
return KeyWithInfo(); return KeyWithInfo();
} }
size_t StorageS3QueueSource::QueueGlobIterator::estimatedKeysCount()
{
return keys_buf.size();
}
StorageS3QueueSource::StorageS3QueueSource( StorageS3QueueSource::StorageS3QueueSource(
const ReadFromFormatInfo & info, const ReadFromFormatInfo & info,
const String & format_, const String & format_,

2
src/Storages/S3Queue/S3QueueSource.h
View File

@ -54,6 +54,8 @@ public:
Strings Strings
filterProcessingFiles(const S3QueueMode & engine_mode, std::unordered_set<String> & exclude_keys, const String & max_file = ""); filterProcessingFiles(const S3QueueMode & engine_mode, std::unordered_set<String> & exclude_keys, const String & max_file = "");
size_t estimatedKeysCount() override;
private: private:
UInt64 max_poll_size; UInt64 max_poll_size;
KeysWithInfo keys_buf; KeysWithInfo keys_buf;