OmniSciDB
bf83d84833
|
#include <CsvFileBufferParser.h>
Public Member Functions | |
ParseBufferRequest (const ParseBufferRequest &request)=delete | |
ParseBufferRequest (ParseBufferRequest &&request)=default | |
ParseBufferRequest (size_t buffer_size, const import_export::CopyParams ©_params, int db_id, const ForeignTable *foreign_table, std::set< int > column_filter_set) | |
std::shared_ptr < Catalog_Namespace::Catalog > | getCatalog () const |
std::list< const ColumnDescriptor * > | getColumns () const |
int32_t | getTableId () const |
std::string | getTableName () const |
size_t | getMaxFragRows () const |
std::string | getFilePath () const |
Public Attributes | |
std::unique_ptr< char[]> | buffer |
size_t | buffer_size |
size_t | buffer_alloc_size |
const import_export::CopyParams | copy_params |
const int | db_id |
std::unique_ptr < ForeignTableSchema > | foreign_table_schema |
std::vector< std::unique_ptr < import_export::TypedImportBuffer > > | import_buffers |
size_t | buffer_row_count |
size_t | begin_pos |
size_t | end_pos |
size_t | first_row_index |
size_t | file_offset |
size_t | process_row_count |
Definition at line 253 of file CsvFileBufferParser.h.
|
delete |
|
default |
|
inline |
Definition at line 256 of file CsvFileBufferParser.h.
References getCatalog(), getColumns(), import_buffers, IS_STRING, and kENCODING_DICT.
|
inline |
Definition at line 287 of file CsvFileBufferParser.h.
References Catalog_Namespace::SysCatalog::checkedGetCatalog(), db_id, and Catalog_Namespace::SysCatalog::instance().
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and ParseBufferRequest().
|
inline |
Definition at line 291 of file CsvFileBufferParser.h.
References foreign_table_schema.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and ParseBufferRequest().
|
inline |
Definition at line 307 of file CsvFileBufferParser.h.
References foreign_table_schema.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and foreign_storage::process_data_blocks().
|
inline |
Definition at line 303 of file CsvFileBufferParser.h.
References foreign_table_schema.
Referenced by foreign_storage::process_data_blocks().
|
inline |
Definition at line 295 of file CsvFileBufferParser.h.
References foreign_table_schema.
Referenced by foreign_storage::process_data_blocks().
|
inline |
Definition at line 299 of file CsvFileBufferParser.h.
References foreign_table_schema.
size_t foreign_storage::csv_file_buffer_parser::ParseBufferRequest::begin_pos |
Definition at line 322 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and foreign_storage::parse_file_regions().
std::unique_ptr<char[]> foreign_storage::csv_file_buffer_parser::ParseBufferRequest::buffer |
Definition at line 312 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and foreign_storage::parse_file_regions().
size_t foreign_storage::csv_file_buffer_parser::ParseBufferRequest::buffer_alloc_size |
Definition at line 314 of file CsvFileBufferParser.h.
size_t foreign_storage::csv_file_buffer_parser::ParseBufferRequest::buffer_row_count |
Definition at line 321 of file CsvFileBufferParser.h.
size_t foreign_storage::csv_file_buffer_parser::ParseBufferRequest::buffer_size |
Definition at line 313 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and foreign_storage::parse_file_regions().
const import_export::CopyParams foreign_storage::csv_file_buffer_parser::ParseBufferRequest::copy_params |
Definition at line 315 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), omnisci.thrift.ttypes.TDetectResult::read(), omnisci.thrift.OmniSci.detect_column_types_args::read(), omnisci.thrift.OmniSci.import_table_args::read(), omnisci.thrift.OmniSci.import_geo_table_args::read(), omnisci.thrift.OmniSci.get_first_geo_file_in_archive_args::read(), omnisci.thrift.OmniSci.get_all_files_in_archive_args::read(), omnisci.thrift.OmniSci.get_layers_in_geo_file_args::read(), omnisci.thrift.ttypes.TDetectResult::write(), omnisci.thrift.OmniSci.detect_column_types_args::write(), omnisci.thrift.OmniSci.import_table_args::write(), omnisci.thrift.OmniSci.import_geo_table_args::write(), omnisci.thrift.OmniSci.get_first_geo_file_in_archive_args::write(), omnisci.thrift.OmniSci.get_all_files_in_archive_args::write(), and omnisci.thrift.OmniSci.get_layers_in_geo_file_args::write().
const int foreign_storage::csv_file_buffer_parser::ParseBufferRequest::db_id |
Definition at line 316 of file CsvFileBufferParser.h.
Referenced by getCatalog(), foreign_storage::process_data_blocks(), omnisci.thrift.ttypes.TInsertData::read(), omnisci.thrift.OmniSci.set_table_epoch_args::read(), omnisci.thrift.OmniSci.get_table_epoch_args::read(), omnisci.thrift.OmniSci.get_table_epochs_args::read(), omnisci.thrift.OmniSci.set_table_epochs_args::read(), omnisci.thrift.ttypes.TInsertData::write(), omnisci.thrift.OmniSci.set_table_epoch_args::write(), omnisci.thrift.OmniSci.get_table_epoch_args::write(), omnisci.thrift.OmniSci.get_table_epochs_args::write(), and omnisci.thrift.OmniSci.set_table_epochs_args::write().
size_t foreign_storage::csv_file_buffer_parser::ParseBufferRequest::end_pos |
Definition at line 323 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and foreign_storage::parse_file_regions().
size_t foreign_storage::csv_file_buffer_parser::ParseBufferRequest::file_offset |
Definition at line 325 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and foreign_storage::parse_file_regions().
size_t foreign_storage::csv_file_buffer_parser::ParseBufferRequest::first_row_index |
Definition at line 324 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), foreign_storage::parse_file_regions(), and foreign_storage::process_data_blocks().
std::unique_ptr<ForeignTableSchema> foreign_storage::csv_file_buffer_parser::ParseBufferRequest::foreign_table_schema |
Definition at line 317 of file CsvFileBufferParser.h.
Referenced by getColumns(), getFilePath(), getMaxFragRows(), getTableId(), and getTableName().
std::vector<std::unique_ptr<import_export::TypedImportBuffer> > foreign_storage::csv_file_buffer_parser::ParseBufferRequest::import_buffers |
Definition at line 318 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), ParseBufferRequest(), and foreign_storage::csv_file_buffer_parser::skip_column_import().
size_t foreign_storage::csv_file_buffer_parser::ParseBufferRequest::process_row_count |
Definition at line 326 of file CsvFileBufferParser.h.
Referenced by foreign_storage::csv_file_buffer_parser::parse_buffer(), and foreign_storage::parse_file_regions().