OmniSciDB
c1a53651b2
|
Functions | |
std::string | abs_path (const File_Namespace::GlobalFileMgr *global_file_mgr) |
std::string | run (const std::string &cmd, const std::string &chdir="") |
std::string | simple_file_cat (const std::string &archive_path, const std::string &file_name, const std::string &compression) |
std::string | get_table_schema (const std::string &archive_path, const std::string &table, const std::string &compression) |
void | rewrite_column_ids_in_page_headers (const boost::filesystem::path &path, const std::unordered_map< int, int > &column_ids_map, const int32_t table_epoch) |
void | adjust_altered_table_files (const int32_t table_epoch, const std::string &temp_data_dir, const std::unordered_map< int, int > &column_ids_map) |
void | delete_old_symlinks (const std::string &table_data_dir) |
void | add_data_file_symlinks (const std::string &table_data_dir) |
void | rename_table_directories (const File_Namespace::GlobalFileMgr *global_file_mgr, const std::string &temp_data_dir, const std::vector< std::string > &target_paths, const std::string &name_prefix) |
Variables | |
auto | simple_file_closer = [](FILE* f) { std::fclose(f); } |
|
inline |
Definition at line 78 of file TableArchiver.cpp.
References File_Namespace::GlobalFileMgr::getBasePath().
Referenced by TableArchiver::dumpTable(), rename_table_directories(), and TableArchiver::restoreTable().
void anonymous_namespace{TableArchiver.cpp}::add_data_file_symlinks | ( | const std::string & | table_data_dir | ) |
Definition at line 285 of file TableArchiver.cpp.
References DATA_FILE_EXT, and File_Namespace::kLegacyDataFileExtension.
Referenced by rename_table_directories().
void anonymous_namespace{TableArchiver.cpp}::adjust_altered_table_files | ( | const int32_t | table_epoch, |
const std::string & | temp_data_dir, | ||
const std::unordered_map< int, int > & | column_ids_map | ||
) |
Definition at line 254 of file TableArchiver.cpp.
References ThreadController_NS::SimpleThreadController< FutureReturnType >::checkThreadsStatus(), cpu_threads(), ThreadController_NS::SimpleThreadController< FutureReturnType >::finish(), rewrite_column_ids_in_page_headers(), and ThreadController_NS::SimpleThreadController< FutureReturnType >::startThread().
Referenced by TableArchiver::restoreTable().
void anonymous_namespace{TableArchiver.cpp}::delete_old_symlinks | ( | const std::string & | table_data_dir | ) |
Definition at line 272 of file TableArchiver.cpp.
Referenced by rename_table_directories().
|
inline |
Definition at line 172 of file TableArchiver.cpp.
References simple_file_cat(), and table_schema_filename.
Referenced by TableArchiver::restoreTable().
void anonymous_namespace{TableArchiver.cpp}::rename_table_directories | ( | const File_Namespace::GlobalFileMgr * | global_file_mgr, |
const std::string & | temp_data_dir, | ||
const std::vector< std::string > & | target_paths, | ||
const std::string & | name_prefix | ||
) |
Definition at line 304 of file TableArchiver.cpp.
References abs_path(), add_data_file_symlinks(), delete_old_symlinks(), and File_Namespace::FileMgr::renameAndSymlinkLegacyFiles().
Referenced by TableArchiver::restoreTable().
void anonymous_namespace{TableArchiver.cpp}::rewrite_column_ids_in_page_headers | ( | const boost::filesystem::path & | path, |
const std::unordered_map< int, int > & | column_ids_map, | ||
const int32_t | table_epoch | ||
) |
Definition at line 183 of file TableArchiver.cpp.
References CHECK, DATA_FILE_EXT, heavyai::file_size(), heavyai::fopen(), File_Namespace::is_page_deleted_with_checkpoint(), simple_file_closer, split(), and to_string().
Referenced by adjust_altered_table_files().
|
inline |
Definition at line 82 of file TableArchiver.cpp.
References logger::ERROR, measure< TimeT >::execution(), LOG, to_lower(), to_string(), and VLOG.
|
inline |
Definition at line 151 of file TableArchiver.cpp.
References get_quoted_string(), ddl_utils::IMPORT, run, and ddl_utils::validate_allowed_file_path().
Referenced by get_table_schema(), and TableArchiver::restoreTable().
|
inline |
Definition at line 76 of file TableArchiver.cpp.
Referenced by TableArchiver::dumpTable(), and rewrite_column_ids_in_page_headers().