Class foreign_storage::RowGroupIntervalTracker¶

class RowGroupIntervalTracker : public foreign_storage::AbstractRowGroupIntervalTracker ¶

Public Functions

RowGroupIntervalTracker(const std::set<std::string> &file_paths, FileReaderMap *file_reader_cache, std::shared_ptr<arrow::fs::FileSystem> file_system)¶

std::optional<RowGroupInterval> getNextRowGroupInterval()¶

Private Functions

bool filesAreExhausted()¶

void advanceToNextRowGroup()¶

Private Members

std::set<std::string> file_paths_¶

FileReaderMap *file_reader_cache_¶

std::shared_ptr<arrow::fs::FileSystem> file_system_¶

bool is_initialized_¶

int num_row_groups_¶

int current_row_group_index_¶

std::set<std::string>::const_iterator current_file_iter_¶