Method fillData

src/Storages/System/StorageSystemQueryQueue.cpp:22–32

}

void StorageSystemQueryQueue::fillData(MutableColumns & res_columns, ContextPtr context, const SelectQueryInfo &) const
{
    context->getQueueManager()->getQueueInfo([&](const QueueInfoPtr & queue_info_ptr) {
        size_t i = 0;
        res_columns[i++]->insert(queue_info_ptr->query_id);
        res_columns[i++]->insert(queue_info_ptr->vw_name);
        res_columns[i++]->insert(queue_info_ptr->wg_name);
        res_columns[i++]->insert(queue_info_ptr->enqueue_time);
        res_columns[i++]->insert(queue_info_ptr->sw.elapsedMilliseconds());
    });
}

}