blob: b6f62e1218f2b16c7765a57c5061fa8d24297459 (
plain) (
blame)
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
38
39
40
41
|
#pragma once
#include <base/types.h>
#include <Core/Names.h>
#include <optional>
#include <map>
#include <ctime>
namespace DB
{
struct MergeTreeMutationStatus
{
String id = "";
String command = "";
time_t create_time = 0;
std::map<String, Int64> block_numbers{};
/// Parts that should be mutated/merged or otherwise moved to Obsolete state for this mutation to complete.
Names parts_to_do_names = {};
/// If the mutation is done. Note that in case of ReplicatedMergeTree parts_to_do == 0 doesn't imply is_done == true.
bool is_done = false;
String latest_failed_part = "";
time_t latest_fail_time = 0;
String latest_fail_reason = "";
/// FIXME: currently unused, but would be much better to report killed mutations with this flag.
bool is_killed = false;
};
/// Check mutation status and throw exception in case of error during mutation
/// (latest_fail_reason not empty) or if mutation was killed (status empty
/// optional). mutation_ids passed separately, because status may be empty and
/// we can execute multiple mutations at once
void checkMutationStatus(std::optional<MergeTreeMutationStatus> & status, const std::set<String> & mutation_ids);
}
|
