#pragma once #include #include #include namespace DB { class StatusAccumulator { public: struct TableStatus { size_t all_partitions_count; size_t processed_partitions_count; }; using Map = std::unordered_map; using MapPtr = std::shared_ptr; static MapPtr fromJSON(String state_json); static String serializeToJSON(MapPtr statuses); }; }