Method fillData

src/Storages/System/StorageSystemVirtualWarehouseQueryQueue.cpp:30–88

}

void StorageSystemVirtualWarehouseQueryQueue::fillData(MutableColumns & res_columns, ContextPtr context, const SelectQueryInfo &) const
{
    auto all_vw = context->getVirtualWarehousePool().getAll();
    for (auto iter = all_vw.begin(); iter != all_vw.end(); iter++)
    {
        iter->second->getQueueManager().fillSystemTable([&](VirtualWarehouseQueue & queue) {

            const auto rules = queue.getRules();
            if (rules.empty())
            {
                size_t i = 0;
                res_columns[i++]->insert(iter->first);
                res_columns[i++]->insert(queue.queueName());
                res_columns[i++]->insert(queue.maxConcurrency());
                res_columns[i++]->insert(queue.queryQueueSize());
                DB::Array tmp;
                res_columns[i++]->insert("");
                res_columns[i++]->insert(tmp);
                res_columns[i++]->insert(tmp);
                res_columns[i++]->insert("");
                res_columns[i++]->insert("");
                res_columns[i++]->insert("");
                res_columns[i++]->insert("");
            }
            else
            {
                for (const auto & rule : rules)
                {
                    size_t i = 0;
                    res_columns[i++]->insert(iter->first);
                    res_columns[i++]->insert(queue.queueName());
                    res_columns[i++]->insert(queue.maxConcurrency());
                    res_columns[i++]->insert(queue.queryQueueSize());
                    res_columns[i++]->insert(rule.rule_name);
                    DB::Array tmp;
                    tmp.reserve(rule.databases.size());
                    for (const auto & database : rule.databases)
                    {
                        tmp.emplace_back(database); 
                    }
                    res_columns[i++]->insert(tmp);

                    tmp.clear();
                    for (const auto & table : rule.tables)
                    {
                        tmp.emplace_back(table); 
                    }
                    res_columns[i++]->insert(tmp);
                    res_columns[i++]->insert(rule.user);
                    res_columns[i++]->insert(rule.ip);
                    res_columns[i++]->insert(rule.query_id);
                    res_columns[i++]->insert(rule.fingerprint);
                }
            }
            

        });
    }