Class import_export::DataStreamSink¶

class DataStreamSink¶

Subclassed by import_export::Detector, import_export::Importer

Public Functions

DataStreamSink()¶

DataStreamSink(const CopyParams &copy_params, const std::string file_path)¶

virtual ~DataStreamSink()¶

virtual ImportStatus importDelimited(const std::string &file_path, const bool decompressed, const Catalog_Namespace::SessionInfo *session_info) = 0¶

const CopyParams &get_copy_params() const¶

void import_compressed(std::vector<std::string> &file_paths, const Catalog_Namespace::SessionInfo *session_info)¶

Protected Functions

ImportStatus archivePlumber(const Catalog_Namespace::SessionInfo *session_info)¶

Protected Attributes

CopyParams copy_params¶

const std::string file_path¶

FILE *p_file = nullptr¶

ImportStatus import_status_¶

mapd_shared_mutex import_mutex_¶

size_t total_file_size = {0}¶

std::vector<size_t> file_offsets¶

std::mutex file_offsets_mutex¶