| 33 | } |
| 34 | |
| 35 | void ReplicatedMergeTreeMutationEntry::readText(ReadBuffer & in) |
| 36 | { |
| 37 | in >> "format version: 1\n"; |
| 38 | |
| 39 | LocalDateTime create_time_dt; |
| 40 | in >> "create time: " >> create_time_dt >> "\n"; |
| 41 | create_time = makeDateTime(DateLUT::serverTimezoneInstance(), |
| 42 | create_time_dt.year(), create_time_dt.month(), create_time_dt.day(), |
| 43 | create_time_dt.hour(), create_time_dt.minute(), create_time_dt.second()); |
| 44 | |
| 45 | in >> "source replica: " >> source_replica >> "\n"; |
| 46 | |
| 47 | size_t count = 0; |
| 48 | in >> "block numbers count: " >> count >> "\n"; |
| 49 | for (size_t i = 0; i < count; ++i) |
| 50 | { |
| 51 | String partition_id; |
| 52 | Int64 number = 0; |
| 53 | in >> partition_id >> "\t" >> number >> "\n"; |
| 54 | block_numbers[partition_id] = number; |
| 55 | } |
| 56 | |
| 57 | in >> "commands: "; |
| 58 | commands.readText(in, false); |
| 59 | if (checkString("\nalter version: ", in)) |
| 60 | in >> alter_version; |
| 61 | } |
| 62 | |
| 63 | String ReplicatedMergeTreeMutationEntry::toString() const |
| 64 | { |
no test coverage detected