OmniSciDB
a5dc49c757
|
#include "TableArchiver/TableArchiver.h"
#include <algorithm>
#include <boost/filesystem.hpp>
#include <boost/process.hpp>
#include <boost/range/combine.hpp>
#include <boost/uuid/uuid_generators.hpp>
#include <boost/uuid/uuid_io.hpp>
#include <boost/version.hpp>
#include <cerrno>
#include <cstdio>
#include <cstring>
#include <exception>
#include <list>
#include <memory>
#include <regex>
#include <set>
#include <sstream>
#include <system_error>
#include "Archive/S3Archive.h"
#include "DataMgr/FileMgr/FileInfo.h"
#include "DataMgr/FileMgr/FileMgr.h"
#include "DataMgr/FileMgr/GlobalFileMgr.h"
#include "LockMgr/LockMgr.h"
#include "Logger/Logger.h"
#include "Parser/ParserNode.h"
#include "Shared/File.h"
#include "Shared/StringTransform.h"
#include "Shared/SysDefinitions.h"
#include "Shared/ThreadController.h"
#include "Shared/file_path_util.h"
#include "Shared/measure.h"
#include "Shared/scope.h"
#include "Shared/thread_count.h"
Go to the source code of this file.
Classes | |
struct | std::tuple_size< boost::tuples::cons< T, U > > |
struct | std::tuple_element< I, boost::tuples::cons< T, U > > |
Namespaces | |
std | |
anonymous_namespace{TableArchiver.cpp} | |
Functions | |
std::string | anonymous_namespace{TableArchiver.cpp}::abs_path (const File_Namespace::GlobalFileMgr *global_file_mgr) |
std::string | anonymous_namespace{TableArchiver.cpp}::run (const std::string &cmd, const std::string &chdir="", const bool log_failure=true) |
std::string | anonymous_namespace{TableArchiver.cpp}::simple_file_cat (const std::string &archive_path, const std::string &file_name, const std::string &compression, const bool log_failure=true) |
std::string | anonymous_namespace{TableArchiver.cpp}::get_table_schema (const std::string &archive_path, const std::string &table, const std::string &compression) |
void | anonymous_namespace{TableArchiver.cpp}::update_or_drop_column_ids_in_page_headers (const boost::filesystem::path &path, const std::unordered_map< int, int > &column_ids_map, const int32_t table_epoch, const bool drop_not_update) |
void | anonymous_namespace{TableArchiver.cpp}::update_or_drop_column_ids_in_table_files (const int32_t table_epoch, const std::string &temp_data_dir, const std::unordered_map< int, int > &column_ids_map, const bool drop_not_update) |
void | anonymous_namespace{TableArchiver.cpp}::delete_old_symlinks (const std::string &table_data_dir) |
void | anonymous_namespace{TableArchiver.cpp}::add_data_file_symlinks (const std::string &table_data_dir) |
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) |
std::unordered_map< int, int > | anonymous_namespace{TableArchiver.cpp}::find_render_group_columns (const std::list< ColumnDescriptor > &src_columns, std::vector< std::string > &src_oldinfo_strs, const std::string &archive_path) |
void | anonymous_namespace{TableArchiver.cpp}::drop_render_group_columns (const std::unordered_map< int, int > &render_group_column_ids, const std::string &archive_path, const std::string &temp_data_dir, const std::string &compression) |
Variables | |
bool | g_cluster |
std::string | g_base_path |
bool | g_test_rollback_dump_restore {false} |
static constexpr int | kDumpVersion = 1 |
static constexpr int | kDumpVersion_remove_render_group_columns = 1 |
static constexpr char const * | table_schema_filename = "_table.sql" |
static constexpr char const * | table_oldinfo_filename = "_table.oldinfo" |
static constexpr char const * | table_epoch_filename = "_table.epoch" |
static constexpr char const * | table_dumpversion_filename = "_table.dumpversion" |
auto | anonymous_namespace{TableArchiver.cpp}::simple_file_closer = [](FILE* f) { std::fclose(f); } |
std::string g_base_path |
Definition at line 62 of file SysCatalog.cpp.
Referenced by Catalog_Namespace::Catalog::buildDictionaryMapUnlocked(), Catalog_Namespace::Catalog::delDictionaryNontransactional(), Parser::ExportQueryStmt::execute(), lockmgr::TableLockMgrImpl< T >::getClusterTableMutex(), DBHandler::initialize(), main(), QueryRunner::QueryRunner::QueryRunner(), Catalog_Namespace::Catalog::reloadDictionariesFromDiskUnlocked(), Catalog_Namespace::Catalog::setColumnDictionary(), and Catalog_Namespace::Catalog::updateDictionaryNames().
bool g_cluster |
bool g_test_rollback_dump_restore {false} |
Definition at line 55 of file TableArchiver.cpp.
Referenced by TableArchiver::restoreTable().
|
static |
Definition at line 57 of file TableArchiver.cpp.
Referenced by TableArchiver::dumpTable().
|
static |
Definition at line 58 of file TableArchiver.cpp.
Referenced by TableArchiver::restoreTable().
|
static |
Definition at line 63 of file TableArchiver.cpp.
Referenced by TableArchiver::dumpTable(), and TableArchiver::restoreTable().
|
static |
Definition at line 62 of file TableArchiver.cpp.
Referenced by anonymous_namespace{TableArchiver.cpp}::drop_render_group_columns(), TableArchiver::dumpTable(), and TableArchiver::restoreTable().
|
static |
Definition at line 61 of file TableArchiver.cpp.
Referenced by TableArchiver::dumpTable(), and TableArchiver::restoreTable().
|
static |
Definition at line 60 of file TableArchiver.cpp.
Referenced by TableArchiver::dumpTable(), and anonymous_namespace{TableArchiver.cpp}::get_table_schema().