Class foreign_storage::ParquetImportBatchResult¶

class ParquetImportBatchResult : public import_export::ImportBatchResult ¶

Public Functions

ParquetImportBatchResult()¶

ParquetImportBatchResult(const ForeignTable *foreign_table, const int db_id, const ForeignTableSchema *schema)¶

ParquetImportBatchResult(ParquetImportBatchResult &&other)¶

std::optional<Fragmenter_Namespace::InsertData> getInsertData() const¶

import_export::ImportStatus getImportStatus() const¶

std::pair<std::map<int, Chunk_NS::Chunk>, std::map<int, StringDictionary *>> getChunksAndDictionaries() const¶

void populateInsertData(const std::map<int, Chunk_NS::Chunk> &chunks)¶

void populateImportStatus(const size_t num_rows_completed, const size_t num_rows_rejected)¶

Private Members

std::optional<Fragmenter_Namespace::InsertData> insert_data_¶

std::map<int, std::unique_ptr<AbstractBuffer>> import_buffers_¶

const ForeignTable *foreign_table_¶

int db_id_¶

const ForeignTableSchema *schema_¶

import_export::ImportStatus import_status_¶