contrib/clickhouse/src/Storages/MergeTree/MovesList.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

#include <Storages/MergeTree/MovesList.h>
#include <Common/CurrentMetrics.h>
#include <base/getThreadId.h>

namespace DB
{

MovesListElement::MovesListElement(
        const StorageID & table_id_,
        const std::string & part_name_,
        const std::string & target_disk_name_,
        const std::string & target_disk_path_,
        UInt64 part_size_)
    : table_id(table_id_)
    , part_name(part_name_)
    , target_disk_name(target_disk_name_)
    , target_disk_path(target_disk_path_)
    , part_size(part_size_)
    , thread_id(getThreadId())
{
}

MoveInfo MovesListElement::getInfo() const
{
    MoveInfo res;
    res.database = table_id.database_name;
    res.table = table_id.table_name;
    res.part_name = part_name;
    res.target_disk_name = target_disk_name;
    res.target_disk_path = target_disk_path;
    res.part_size = part_size;
    res.elapsed = watch.elapsedSeconds();
    res.thread_id = thread_id;
    return res;
}

}