| 1271 | } |
| 1272 | |
| 1273 | void InterpreterSystemQuery::executeCheckpoint(const ASTSystemQuery & ) |
| 1274 | { |
| 1275 | auto local_context = getContext(); |
| 1276 | if (auto server_type = local_context->getServerType(); server_type != ServerType::cnch_server) |
| 1277 | throw Exception("SYSTEM CHECKPOINT is only available on CNCH server", ErrorCodes::NOT_IMPLEMENTED); |
| 1278 | |
| 1279 | auto storage = DatabaseCatalog::instance().getTable(table_id, local_context); |
| 1280 | CnchManifestCheckpointThread checkpoint_thread(local_context, storage->getStorageID()); |
| 1281 | checkpoint_thread.executeManually(); |
| 1282 | } |
| 1283 | |
| 1284 | void InterpreterSystemQuery::dedupWithHighPriority(const ASTSystemQuery & query) |
| 1285 | { |
nothing calls this directly
no test coverage detected