Method executeDumpWorkloadImpl

src/Interpreters/InterpreterDumpQuery.cpp:186–198

}

void InterpreterDumpQuery::executeDumpWorkloadImpl()
{
    // obtain query logs
    String query_log_scan = prepareQueryLogSQL();
    LOG_DEBUG(log, "querying query_log with: {}", query_log_scan);
    BlockIO query_log_res = executeQuery(query_log_scan, Context::createCopy(getContext()), /*internal=*/true);
    BlockInputStreamPtr query_log_block_stream = query_log_res.getInputStream();

    while (Block block = query_log_block_stream->read())
    {
        processQueryLogBlock(block);
    }
}

void InterpreterDumpQuery::processQueryLogBlock(const Block & block)
{