ClickHouse/dbms/src/Interpreters/ExternalModelsLoader.cpp

#include <Interpreters/ExternalModelsLoader.h>
#include <Interpreters/Context.h>

namespace DB
{

namespace ErrorCodes
{
    extern const int INVALID_CONFIG_PARAMETER;
}


ExternalModelsLoader::ExternalModelsLoader(
    ExternalLoaderConfigRepositoryPtr config_repository, Context & context_)
    : ExternalLoader("external model", &Logger::get("ExternalModelsLoader"))
    , context(context_)
{
    addConfigRepository("_XMLConfigRepository", std::move(config_repository), {"model", "name"});
    enablePeriodicUpdates(true);
}

std::shared_ptr<const IExternalLoadable> ExternalModelsLoader::create(
        const std::string & name, const Poco::Util::AbstractConfiguration & config, const std::string & config_prefix) const
{
    String type = config.getString(config_prefix + ".type");
    ExternalLoadableLifetime lifetime(config, config_prefix + ".lifetime");

    /// TODO: add models factory.
    if (type == "catboost")
    {
        return std::make_unique<CatBoostModel>(
                name, config.getString(config_prefix + ".path"),
                context.getConfigRef().getString("catboost_dynamic_library_path"),
                lifetime
        );
    }
    else
    {
        throw Exception("Unknown model type: " + type, ErrorCodes::INVALID_CONFIG_PARAMETER);
    }
}

}