thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 07:31:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

dbms: development [#CONV-2944].

Browse Source
This commit is contained in:
Alexey Milovidov 2012-07-31 20:13:14 +00:00
parent 76c691f96a
commit 19a3e788e9
1 changed files with 40 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -973,9 +973,47 @@ void StorageMergeTree::loadDataParts()
all_data_parts = *new_data_parts;
}
/// Удаляем из набора актуальных кусков куски, которые содержатся в другом куске (которые были склеены).
// TODO
/** Удаляем из набора актуальных кусков куски, которые содержатся в другом куске (которые были склеены),
* но по каким-то причинам остались лежать в файловой системе.
* Удаление файлов будет произведено потом в методе clearOldParts.
*/
DataParts::iterator prev_jt = new_data_parts->begin();
DataParts::iterator curr_jt = prev_jt;
++curr_jt;
while (curr_jt != new_data_parts->end())
{
/// Куски данных за разные месяцы рассматривать не будем
if ((*curr_jt)->left_month != (*curr_jt)->right_month
|| (*curr_jt)->right_month != (*prev_jt)->left_month
|| (*prev_jt)->left_month != (*prev_jt)->right_month)
{
++prev_jt;
++curr_jt;
continue;
}
if ((*curr_jt)->contains(**prev_jt))
{
LOG_WARNING(log, "Part " << (*curr_jt)->name << " contains " << (*prev_jt)->name);
new_data_parts->erase(prev_jt);
prev_jt = curr_jt;
++curr_jt;
}
else if ((*prev_jt)->contains(**curr_jt))
{
LOG_WARNING(log, "Part " << (*prev_jt)->name << " contains " << (*curr_jt)->name);
new_data_parts->erase(curr_jt++);
}
else
{
++prev_jt;
++curr_jt;
}
}
/** Устанавливаем актуальную версию набора кусков.
*/
data_parts.set(new_data_parts);
LOG_DEBUG(log, "Loaded data parts (" << new_data_parts->size() << " items)");