OmniSciDB
4201147b46
|
Functions | |
std::string | get_data_wrapper_type (const import_export::CopyParams ©_params) |
ChunkMetadataVector | metadata_scan (foreign_storage::ForeignDataWrapper *data_wrapper, foreign_storage::ForeignTable *foreign_table) |
void | validate_copy_params (const import_export::CopyParams ©_params) |
import_export::ImportStatus | import_foreign_data (const ChunkMetadataVector &metadata_vector, Fragmenter_Namespace::InsertDataLoader::InsertConnector *connector, Catalog_Namespace::Catalog &catalog, const TableDescriptor *table, foreign_storage::ForeignDataWrapper *data_wrapper, const Catalog_Namespace::SessionInfo *session_info, const import_export::CopyParams ©_params, const std::string ©_from_source) |
std::string anonymous_namespace{ForeignDataImporter.cpp}::get_data_wrapper_type | ( | const import_export::CopyParams & | copy_params | ) |
Definition at line 44 of file ForeignDataImporter.cpp.
References foreign_storage::DataWrapperType::CSV, import_export::kDelimitedFile, import_export::kParquetFile, import_export::kRegexParsedFile, foreign_storage::DataWrapperType::PARQUET, foreign_storage::DataWrapperType::REGEX_PARSER, import_export::CopyParams::source_type, and UNREACHABLE.
Referenced by import_export::ForeignDataImporter::importGeneral().
import_export::ImportStatus anonymous_namespace{ForeignDataImporter.cpp}::import_foreign_data | ( | const ChunkMetadataVector & | metadata_vector, |
Fragmenter_Namespace::InsertDataLoader::InsertConnector * | connector, | ||
Catalog_Namespace::Catalog & | catalog, | ||
const TableDescriptor * | table, | ||
foreign_storage::ForeignDataWrapper * | data_wrapper, | ||
const Catalog_Namespace::SessionInfo * | session_info, | ||
const import_export::CopyParams & | copy_params, | ||
const std::string & | copy_from_source | ||
) |
Definition at line 90 of file ForeignDataImporter.cpp.
References CHECK, CHECK_GE, CHECK_LE, CHUNK_KEY_COLUMN_IDX, CHUNK_KEY_FRAGMENT_IDX, CHUNK_KEY_TABLE_IDX, CHUNK_KEY_VARLEN_IDX, foreign_storage::ForeignDataWrapper::createRenderGroupAnalyzers(), g_enable_assign_render_groups, import_export::CopyParams::geo_assign_render_groups, shared::get_from_map(), Chunk_NS::Chunk::getChunk(), Catalog_Namespace::Catalog::getDatabaseId(), Catalog_Namespace::Catalog::getMetadataForColumn(), Fragmenter_Namespace::InsertDataLoader::insertChunks(), import_export::ImportStatus::load_failed, import_export::ImportStatus::load_msg, import_export::CopyParams::max_reject, foreign_storage::ForeignDataWrapper::populateChunkBuffers(), import_export::ImportStatus::rows_completed, import_export::ImportStatus::rows_rejected, import_export::Importer::set_import_status(), and TableDescriptor::tableId.
Referenced by import_export::ForeignDataImporter::importGeneral().
ChunkMetadataVector anonymous_namespace{ForeignDataImporter.cpp}::metadata_scan | ( | foreign_storage::ForeignDataWrapper * | data_wrapper, |
foreign_storage::ForeignTable * | foreign_table | ||
) |
Definition at line 60 of file ForeignDataImporter.cpp.
References TableDescriptor::maxFragRows, foreign_storage::MetadataScanInfeasibleFragmentSizeException::min_feasible_fragment_size_, and foreign_storage::ForeignDataWrapper::populateChunkMetadata().
Referenced by import_export::ForeignDataImporter::importGeneral().
void anonymous_namespace{ForeignDataImporter.cpp}::validate_copy_params | ( | const import_export::CopyParams & | copy_params | ) |
Definition at line 84 of file ForeignDataImporter.cpp.
References import_export::kRegexParsedFile, import_export::CopyParams::source_type, and foreign_storage::validate_regex_parser_options().
Referenced by import_export::ForeignDataImporter::importGeneral().