Function batchReadTaskLog

src/Statistics/AutoStatsTaskLogHelper.cpp:49–132

}

std::vector<TaskInfoLog> batchReadTaskLog(ContextPtr context, DateTime64 min_event_time)
{
    std::vector<TaskInfoLog> result;

    auto event_time_str = serializeToText(min_event_time);

    auto event_date = convertToDate(min_event_time);
    auto event_date_str = serializeToText(event_date);

    String table_sql = "system.auto_stats_task_log";
    auto select_sql = fmt::format(
        FMT_STRING(
            " select event_time, task_uuid, task_type, table_uuid, stats_row_count, udi, priority, retry, status, settings_json, columns"
            " from ("
            "    select"
            "    *,"
            "    row_number() over ("
            "        partition by task_uuid"
            "        order by event_time desc"
            "        ) as _tmp__rn"
            "    from {}"
            "    where event_date >= toDate('{}') and event_time >= toDateTime64('{}', 3)"
            " ) "
            " where _tmp__rn=1 and status not in ('Success', 'Failed', 'Cancelled')"),
        table_sql,
        event_date_str,
        event_time_str);

    auto proc_block = [&result](Block & block) {
        auto index_base = result.size();
        result.resize(result.size() + block.rows());
        for (size_t i = 0; i < block.columns(); ++i)
        {
            auto & column = block.safeGetByPosition(i).column;
            for (size_t row = 0; row < block.rows(); ++row)
            {
                auto & task = result[index_base + row];
                switch (i)
                {
                    case 0:
                        task.event_time = column->get64(row);
                        break;
                    case 1:
                        task.task_uuid = getUUID(column, row);
                        break;
                    case 2:
                        task.task_type = static_cast<TaskType>(column->get64(row));
                        break;
                    case 3:
                        task.table_uuid = getUUID(column, row);
                        break;
                    case 4:
                        task.stats_row_count = column->get64(row);
                        break;
                    case 5:
                        task.udi_count = column->get64(row);
                        break;
                    case 6: