Method updateTaskQueueFromLog

src/Statistics/AutoStatisticsManager.cpp:546–561

return max_event_time of current log

}
// return max_event_time of current log
TimePoint AutoStatisticsManager::updateTaskQueueFromLog(TimePoint min_event_time)
{
    context->getAutoStatsTaskLog()->flush(true);

    /// record current time before read log
    /// in case reading log consume too much time
    auto current_time = nowTimePoint();

    auto task_log_infos = batchReadTaskLog(context, convertToDateTime64(min_event_time));
    for (const auto & task_log_info : task_log_infos)
    {
        task_queue.updateTasksFromLogIfNeeded(task_log_info);
    }

    return current_time;
}

void AutoStatisticsManager::logTaskIfNeeded(
    const StatsTableIdentifier & table, UInt64 udi_count, UInt64 stats_row_count, DateTime64 timestamp)