Class foreign_storage::ForeignTableRefreshScheduler

class ForeignTableRefreshScheduler

Public Static Functions

void start(std::atomic<bool> &is_program_running)

void stop()

void setWaitDuration(int64_t duration_in_seconds)

bool isRunning()

bool hasRefreshedTable()

void resetHasRefreshedTable()

Private Static Functions

void invalidateQueryEngineCaches()

Private Static Attributes

std::atomic<bool> is_scheduler_running_ = {false}

std::chrono::seconds thread_wait_duration_ = {60}

std::thread scheduler_thread_

std::atomic<bool> has_refreshed_table_ = {false}

std::mutex wait_mutex_

std::condition_variable wait_condition_