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

Little improvement for large number of small inserts [#METR-22327].

Browse Source
This commit is contained in:
Alexey Milovidov 2016-11-18 04:03:57 +03:00
parent c9c981e3e9
commit 6d154c1290
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbms/include/DB/Storages/StorageMergeTree.h
View File

@ -119,9 +119,12 @@ private:
MergeTreeDataWriter writer;
MergeTreeDataMerger merger;
/// Для нумерации блоков.
/// For block numbers.
SimpleIncrement increment;
/// For clearOldParts, clearOldTemporaryDirectories.
StopwatchWithLock time_after_previous_cleanup;
MergeTreeData::DataParts currently_merging;
std::mutex currently_merging_mutex;

9
dbms/src/Storages/StorageMergeTree.cpp
View File

@ -297,9 +297,12 @@ bool StorageMergeTree::merge(
const String & partition,
bool final)
{
/// Удаляем старые куски.
data.clearOldParts();
data.clearOldTemporaryDirectories(); /// TODO Делать это реже.
/// Clear old parts. It does not matter to do it more frequently than each second.
if (time_after_previous_cleanup.lockTestAndRestart(1))
{
data.clearOldParts();
data.clearOldTemporaryDirectories();
}
auto structure_lock = lockStructure(true);