Method execute

src/Interpreters/InterpreterAlterDiskCacheQuery.cpp:19–59

}

BlockIO InterpreterAlterDiskCacheQuery::execute()
{
    const auto & query = query_ptr->as<ASTAlterDiskCacheQuery &>();
    /// apply settings
    if (query.settings_ast)
    {
        InterpreterSetQuery(query.settings_ast, getContext()).executeForCurrentContext();
    }

    StoragePtr table = DatabaseCatalog::instance().getTable({query.database, query.table}, getContext());
    auto * storage = dynamic_cast<StorageCnchMergeTree *>(table.get());
    if (!storage)
        throw Exception("Preload only support CnchMergeTree engine", ErrorCodes::LOGICAL_ERROR);

    ServerDataPartsVector parts;
    if (query.partition)
    {
        String partition_id = storage->getPartitionIDFromQuery(query.partition, getContext());
        parts = getContext()->getCnchCatalog()->getServerDataPartsInPartitions(table, {partition_id}, getContext()->getTimestamp(), nullptr);
    }
    else
    {
        parts = storage->getAllPartsWithDBM(getContext()).first;
    }
    parts = CnchPartsHelper::calcVisibleParts(parts, false);

    if (query.type == ASTAlterDiskCacheQuery::Type::PRELOAD)
    {
        storage->sendPreloadTasks(getContext(), std::move(parts), query.sync, getContext()->getSettings().parts_preload_level, time(nullptr));
    }
    else if (query.type == ASTAlterDiskCacheQuery::Type::DROP)
    {
        storage->sendDropDiskCacheTasks(getContext(), std::move(parts), query.sync, getContext()->getSettings().drop_vw_disk_cache);
    }
    else
    {
        throw Exception("Unknown alter disk cache query type", ErrorCodes::NOT_IMPLEMENTED);
    }

    return {};
}
}