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

Switched system.parts.move_ttl_info to separate arrays.

Browse Source
This commit is contained in:
Vladimir Chebotarev 2020-05-11 10:31:26 +03:00
parent 3ed5d9434a
commit 6f68979662
1 changed files with 13 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/Storages/System/StorageSystemParts.cpp
View File

@ -4,7 +4,6 @@
#include <Columns/ColumnString.h> #include <Columns/ColumnString.h>
#include <DataTypes/DataTypeString.h> #include <DataTypes/DataTypeString.h>
#include <DataTypes/DataTypeArray.h> #include <DataTypes/DataTypeArray.h>
#include <DataTypes/DataTypeTuple.h>
#include <DataTypes/DataTypesNumber.h> #include <DataTypes/DataTypesNumber.h>
#include <DataTypes/DataTypeDateTime.h> #include <DataTypes/DataTypeDateTime.h>
#include <DataTypes/DataTypeDate.h> #include <DataTypes/DataTypeDate.h>
@ -55,15 +54,9 @@ StorageSystemParts::StorageSystemParts(const std::string & name_)
{"hash_of_uncompressed_files", std::make_shared<DataTypeString>()}, {"hash_of_uncompressed_files", std::make_shared<DataTypeString>()},
{"uncompressed_hash_of_compressed_files", std::make_shared<DataTypeString>()}, {"uncompressed_hash_of_compressed_files", std::make_shared<DataTypeString>()},
{"move_ttl_info", std::make_shared<DataTypeArray>( {"move_ttl_info.expression", std::make_shared<DataTypeArray>(std::make_shared<DataTypeString>())},
std::make_shared<DataTypeTuple>( {"move_ttl_info.min", std::make_shared<DataTypeArray>(std::make_shared<DataTypeDateTime>())},
DataTypes({ {"move_ttl_info.max", std::make_shared<DataTypeArray>(std::make_shared<DataTypeDateTime>())},
std::make_shared<DataTypeString>(),
std::make_shared<DataTypeDateTime>(),
std::make_shared<DataTypeDateTime>()
}),
Strings({"expression", "min", "max"})
))},
} }
) )
{ {
@ -143,17 +136,19 @@ void StorageSystemParts::processNextStorage(MutableColumns & columns_, const Sto
/// move_ttl_info /// move_ttl_info
{ {
Array move_ttl_info_array; Array expression_array, min_array, max_array;
move_ttl_info_array.reserve(part->ttl_infos.moves_ttl.size()); expression_array.reserve(part->ttl_infos.moves_ttl.size());
min_array.reserve(part->ttl_infos.moves_ttl.size());
max_array.reserve(part->ttl_infos.moves_ttl.size());
for (const auto & [expression, move_ttl_info] : part->ttl_infos.moves_ttl) for (const auto & [expression, move_ttl_info] : part->ttl_infos.moves_ttl)
{ {
Tuple move_ttl_info_tuple; expression_array.emplace_back(expression);
move_ttl_info_tuple.push_back(expression); min_array.push_back(static_cast<UInt32>(move_ttl_info.min));
move_ttl_info_tuple.push_back(static_cast<UInt32>(move_ttl_info.min)); max_array.push_back(static_cast<UInt32>(move_ttl_info.max));
move_ttl_info_tuple.push_back(static_cast<UInt32>(move_ttl_info.max));
move_ttl_info_array.emplace_back(std::move(move_ttl_info_tuple));
} }
columns_[i++]->insert(move_ttl_info_array); columns_[i++]->insert(expression_array);
columns_[i++]->insert(min_array);
columns_[i++]->insert(max_array);
} }
} }
} }