OmniSciDB
a5dc49c757
|
This is the complete list of members for DistributedLoader, including all inherited members.
catalog_ | import_export::Loader | protected |
checkpoint() | import_export::Loader | virtual |
column_descs_ | import_export::Loader | protected |
dict_map_ | import_export::Loader | protected |
DistributedLoader(const Catalog_Namespace::SessionInfo &parent_session_info, const TableDescriptor *t, LeafAggregator *aggregator) | DistributedLoader | inline |
distributeToShards(std::vector< OneShardBuffers > &all_shard_import_buffers, std::vector< size_t > &all_shard_row_counts, const OneShardBuffers &import_buffers, const size_t row_count, const size_t shard_count, const Catalog_Namespace::SessionInfo *session_info) | import_export::Loader | protected |
dropColumns(const std::vector< int > &columns) | import_export::Loader | |
get_column_descs() const | import_export::Loader | inline |
getCatalog() const | import_export::Loader | inline |
getErrorMessage() | import_export::Loader | inline |
getStringDict(const ColumnDescriptor *cd) const | import_export::Loader | inline |
getTableDesc() const | import_export::Loader | inline |
getTableEpochs() const | import_export::Loader | virtual |
init() | import_export::Loader | protected |
insert_data_ | import_export::Loader | protected |
isAddingColumns() const | import_export::Loader | inline |
load(const std::vector< std::unique_ptr< import_export::TypedImportBuffer >> &import_buffers, const size_t row_count, const Catalog_Namespace::SessionInfo *session_info) override | DistributedLoader | inlinevirtual |
load_callback_ | import_export::Loader | protected |
Loader(Catalog_Namespace::Catalog &c, const TableDescriptor *t, LoadCallbackType load_callback=nullptr) | import_export::Loader | inline |
loadImpl(const std::vector< std::unique_ptr< TypedImportBuffer >> &import_buffers, size_t row_count, bool checkpoint, const Catalog_Namespace::SessionInfo *session_info) | import_export::Loader | protectedvirtual |
loadNoCheckpoint(const std::vector< std::unique_ptr< TypedImportBuffer >> &import_buffers, const size_t row_count, const Catalog_Namespace::SessionInfo *session_info) | import_export::Loader | virtual |
OneShardBuffers typedef | import_export::Loader | protected |
setAddingColumns(const bool adding_columns) | import_export::Loader | inline |
setTableEpochs(const std::vector< Catalog_Namespace::TableEpochInfo > &table_epochs) | import_export::Loader | virtual |
table_desc_ | import_export::Loader | protected |
~Loader() | import_export::Loader | inlinevirtual |