17 #ifndef _ROWTOCOLUMNLOADER_H_ 18 #define _ROWTOCOLUMNLOADER_H_ 31 #include <boost/algorithm/string.hpp> 32 #include <boost/algorithm/string/trim.hpp> 33 #include <boost/regex.hpp> 46 #include <boost/program_options.hpp> 49 #include <thrift/protocol/TBinaryProtocol.h> 50 #include <thrift/protocol/TJSONProtocol.h> 51 #include <thrift/transport/TBufferTransports.h> 52 #include <thrift/transport/THttpClient.h> 53 #include <thrift/transport/TSocket.h> 55 #include "gen-cpp/OmniSci.h" 56 #include "gen-cpp/omnisci_types.h" 65 const std::string& user_name,
66 const std::string& passwd,
67 const std::string& db_name,
68 const std::string& table_name);
99 #endif // _ROWTOCOLUMNLOADER_H_ TRowDescriptor get_row_descriptor()
std::string print_row_with_delim(std::vector< TStringValue > row, const import_export::CopyParams ©_params)
void wait_disconnet_reconnnect_retry(size_t tries, import_export::CopyParams copy_params)
Constants for Builtin SQL Types supported by OmniSci.
std::vector< SQLTypeInfo > column_type_info_
void do_load(int &nrows, int &nskipped, import_export::CopyParams copy_params)
std::vector< TColumn > input_columns_
std::vector< SQLTypeInfo > array_column_type_info_
RowToColumnLoader(const ThriftClientConnection &conn_details, const std::string &user_name, const std::string &passwd, const std::string &db_name, const std::string &table_name)
bool convert_string_to_column(std::vector< TStringValue > row, const import_export::CopyParams ©_params)
void createConnection(const ThriftClientConnection &con)
ThriftClientConnection conn_details_
mapd::shared_ptr< OmniSciClient > client_