Class import_export::ForeignDataImporter¶
-
class
ForeignDataImporter: public import_export::AbstractImporter¶ Public Functions
-
ForeignDataImporter(const std::string &file_path, const CopyParams ©_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¶
-