Class import_export::ForeignDataImporter

class ForeignDataImporter : public import_export::AbstractImporter

Public Functions

ForeignDataImporter(const std::string &file_path, const CopyParams &copy_params, const TableDescriptor *table)
ImportStatus import(const Catalog_Namespace::SessionInfo *session_info)

Protected Attributes

std::unique_ptr<Fragmenter_Namespace::InsertDataLoader::DistributedConnector> connector_

Private Functions

void finalize(const Catalog_Namespace::SessionInfo &parent_session_info, ImportStatus &import_status, const std::vector<std::pair<const ColumnDescriptor *, StringDictionary *>> &string_dictionaries)
void finalize(const Catalog_Namespace::SessionInfo &parent_session_info, ImportStatus &import_status, const int32_t table_id)
ImportStatus importGeneral(const Catalog_Namespace::SessionInfo *session_info)

Private Members

std::string copy_from_source_
CopyParams copy_params_
const TableDescriptor *table_

Private Static Attributes

const int32_t proxy_foreign_table_fragment_size_ = 2000000