Class RowToColumnLoader¶

class RowToColumnLoader¶

Public Functions

RowToColumnLoader(const ThriftClientConnection &conn_details, const std::string &user_name, const std::string &passwd, const std::string &db_name, const std::string &table_name)¶

~RowToColumnLoader()¶

void do_load(int &nrows, int &nskipped, import_export::CopyParams copy_params)¶

bool convert_string_to_column(std::vector<TStringValue> row, const import_export::CopyParams &copy_params)¶

TRowDescriptor get_row_descriptor()¶

std::string print_row_with_delim(std::vector<TStringValue> row, const import_export::CopyParams &copy_params)¶

Private Functions

void createConnection(const ThriftClientConnection &con)¶

void closeConnection()¶

void wait_disconnect_reconnect_retry(size_t tries, import_export::CopyParams copy_params)¶

Private Members

std::string user_name_¶

std::string passwd_¶

std::string db_name_¶

std::string table_name_¶

ThriftClientConnection conn_details_¶

std::vector<TColumn> input_columns_¶

std::vector<SQLTypeInfo> column_type_info_¶

std::vector<SQLTypeInfo> array_column_type_info_¶

TRowDescriptor row_desc_¶

std::shared_ptr<OmniSciClient> client_¶

TSessionId session_¶