Function createCachedStatsProxy

src/Statistics/CachedStatsProxy.cpp:213–240

dispatcher

// dispatcher
CachedStatsProxyPtr createCachedStatsProxy(const CatalogAdaptorPtr & catalog, StatisticsCachePolicy policy)
{
    // when enable_memory_catalog is true, we won't use cache
    if (catalog->getSettingsRef().enable_memory_catalog)
    {
        if (policy != StatisticsCachePolicy::Default)
            throw Exception("memory catalog don't support cache policy", ErrorCodes::BAD_ARGUMENTS);

        return std::make_unique<CachedStatsProxyDirectImpl>(catalog);
    }

    if (policy == StatisticsCachePolicy::Default)
    {
        return std::make_unique<CachedStatsProxyImpl<false>>(catalog);
    }
    else if (policy == StatisticsCachePolicy::Catalog)
    {
        return std::make_unique<CachedStatsProxyDirectImpl>(catalog);
    }
    else if (policy == StatisticsCachePolicy::Cache)
    {
        return std::make_unique<CachedStatsProxyImpl<true>>(catalog);
    }
    else
    {
        throw Exception("Unknown statistics cache policy", ErrorCodes::LOGICAL_ERROR);
    }
}


} // namespace DB