archivePlumber(const Catalog_Namespace::SessionInfo *session_info) | import_export::DataStreamSink | protected |
best_encodings | import_export::Detector | private |
best_sqltypes | import_export::Detector | private |
copy_params | import_export::DataStreamSink | protected |
DataStreamSink() | import_export::DataStreamSink | inline |
DataStreamSink(const CopyParams ©_params, const std::string file_path) | import_export::DataStreamSink | inline |
detect_column_types(const std::vector< std::string > &row) | import_export::Detector | private |
detect_headers(const std::vector< SQLTypes > &first_types, const std::vector< SQLTypes > &rest_types) | import_export::Detector | private |
detect_row_delimiter() | import_export::Detector | private |
detect_sqltype(const std::string &str) | import_export::Detector | static |
Detector(const boost::filesystem::path &fp, CopyParams &cp) | import_export::Detector | |
file_offsets | import_export::DataStreamSink | protected |
file_offsets_mutex | import_export::DataStreamSink | protected |
file_path | import_export::Detector | private |
find_best_encodings(const std::vector< std::vector< std::string >>::const_iterator &row_begin, const std::vector< std::vector< std::string >>::const_iterator &row_end, const std::vector< SQLTypes > &best_types) | import_export::Detector | private |
find_best_sqltypes() | import_export::Detector | private |
find_best_sqltypes(const std::vector< std::vector< std::string >> &raw_rows, const CopyParams ©_params) | import_export::Detector | private |
find_best_sqltypes(const std::vector< std::vector< std::string >>::const_iterator &row_begin, const std::vector< std::vector< std::string >>::const_iterator &row_end, const CopyParams ©_params) | import_export::Detector | private |
find_best_sqltypes_and_headers() | import_export::Detector | private |
get_copy_params() const | import_export::DataStreamSink | inline |
get_headers() | import_export::Detector | |
get_sample_rows(size_t n) | import_export::Detector | |
getBestColumnTypes() const | import_export::Detector | |
has_headers | import_export::Detector | |
import_compressed(std::vector< std::string > &file_paths, const Catalog_Namespace::SessionInfo *session_info) | import_export::DataStreamSink | |
import_mutex_ | import_export::DataStreamSink | protected |
import_status_ | import_export::DataStreamSink | protected |
importDelimited(const std::string &file_path, const bool decompressed, const Catalog_Namespace::SessionInfo *session_info) override | import_export::Detector | privatevirtual |
init() | import_export::Detector | private |
line1 | import_export::Detector | private |
more_restrictive_sqltype(const SQLTypes a, const SQLTypes b) | import_export::Detector | privatestatic |
p_file | import_export::DataStreamSink | protected |
raw_data | import_export::Detector | private |
raw_rows | import_export::Detector | |
read_file() | import_export::Detector | private |
split_raw_data() | import_export::Detector | private |
timeout | import_export::Detector | private |
total_file_size | import_export::DataStreamSink | protected |
~DataStreamSink() | import_export::DataStreamSink | inlinevirtual |