thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-23 16:12:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update StorageHudi.cpp

Browse Source
This commit is contained in:
Kseniia Sumarokova 2022-11-07 23:07:00 +01:00 committed by GitHub
parent 891e167509
commit d695240d53
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Storages/StorageHudi.cpp
View File

@ -45,7 +45,7 @@ StorageHudi::StorageHudi(
StorageS3::updateS3Configuration(context_, base_configuration); StorageS3::updateS3Configuration(context_, base_configuration);
auto keys = getKeysFromS3(); auto keys = getKeysFromS3();
auto new_uri = base_configuration.uri.uri.toString() + generateQueryFromKeys(std::move(keys), configuration_.format); auto new_uri = base_configuration.uri.uri.toString() + generateQueryFromKeys(keys, configuration_.format);
LOG_DEBUG(log, "New uri: {}", new_uri); LOG_DEBUG(log, "New uri: {}", new_uri);
LOG_DEBUG(log, "Table path: {}", table_path); LOG_DEBUG(log, "Table path: {}", table_path);
@ -158,7 +158,7 @@ String StorageHudi::generateQueryFromKeys(const std::vector<std::string> & keys,
const String partition_path = key_path.parent_path(); const String partition_path = key_path.parent_path();
/// Every filename contains metadata split by "_", timestamp is after last "_". /// Every filename contains metadata split by "_", timestamp is after last "_".
const auto delim = key.find_last_of("_") + 1; const auto delim = key.find_last_of('_') + 1;
if (delim == std::string::npos) if (delim == std::string::npos)
throw Exception(ErrorCodes::LOGICAL_ERROR, "Unexpected format of metadata files"); throw Exception(ErrorCodes::LOGICAL_ERROR, "Unexpected format of metadata files");
const auto timestamp = parse<UInt64>(key.substr(delim + 1)); const auto timestamp = parse<UInt64>(key.substr(delim + 1));