thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-03 13:02:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix build

Browse Source
This commit is contained in:
Sergei Trifonov 2022-04-07 16:07:12 +02:00
parent 03f76dda1d
commit 01425df758
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/IO/ReadBufferFromS3.cpp
View File

@ -319,7 +319,7 @@ SeekableReadBufferPtr ReadBufferS3Factory::getReader()
client_ptr,
bucket,
key,
verion_id,
version_id,
s3_max_single_read_retries,
read_settings,
false /*use_external_buffer*/,

4
src/Storages/StorageS3.cpp
View File

@ -272,7 +272,7 @@ bool StorageS3Source::initialize()
file_path = fs::path(bucket) / current_key;
read_buf = wrapReadBufferWithCompressionMethod(createS3ReadBuffer(current_key, version_id), chooseCompressionMethod(current_key, compression_hint));
read_buf = wrapReadBufferWithCompressionMethod(createS3ReadBuffer(current_key), chooseCompressionMethod(current_key, compression_hint));
auto input_format = getContext()->getInputFormat(format, *read_buf, sample_block, max_block_size, format_settings);
QueryPipelineBuilder builder;
@ -291,7 +291,7 @@ bool StorageS3Source::initialize()
return true;
}
std::unique_ptr<ReadBuffer> StorageS3Source::createS3ReadBuffer(const String & key, const String & version_id)
std::unique_ptr<ReadBuffer> StorageS3Source::createS3ReadBuffer(const String & key)
{
const size_t object_size = DB::S3::getObjectSize(client, bucket, key, version_id, false);

2
src/Storages/StorageS3.h
View File

@ -112,7 +112,7 @@ private:
/// Recreate ReadBuffer and BlockInputStream for each file.
bool initialize();
std::unique_ptr<ReadBuffer> createS3ReadBuffer(const String & key, const String & version_id);
std::unique_ptr<ReadBuffer> createS3ReadBuffer(const String & key);
};
/**