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_