OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
DistributedLoader Class Reference

#include <DistributedLoader.h>

+ Inheritance diagram for DistributedLoader:
+ Collaboration diagram for DistributedLoader:

Public Member Functions

 DistributedLoader (const Catalog_Namespace::SessionInfo &parent_session_info, const TableDescriptor *t, LeafAggregator *aggregator)
bool load (const std::vector< std::unique_ptr< import_export::TypedImportBuffer >> &import_buffers, const size_t row_count, const Catalog_Namespace::SessionInfo *session_info) override
- Public Member Functions inherited from import_export::Loader
 Loader (Catalog_Namespace::Catalog &c, const TableDescriptor *t, LoadCallbackType load_callback=nullptr)
virtual ~Loader ()
Catalog_Namespace::CataloggetCatalog () const
const TableDescriptorgetTableDesc () const
const std::list< const
ColumnDescriptor * > & 
get_column_descs () const
StringDictionarygetStringDict (const ColumnDescriptor *cd) const
virtual bool loadNoCheckpoint (const std::vector< std::unique_ptr< TypedImportBuffer >> &import_buffers, const size_t row_count, const Catalog_Namespace::SessionInfo *session_info)
virtual void checkpoint ()
virtual std::vector
< Catalog_Namespace::TableEpochInfo
getTableEpochs () const
virtual void setTableEpochs (const std::vector< Catalog_Namespace::TableEpochInfo > &table_epochs)
void setAddingColumns (const bool adding_columns)
bool isAddingColumns () const
void dropColumns (const std::vector< int > &columns)
std::string getErrorMessage ()

Additional Inherited Members

- Protected Types inherited from import_export::Loader
using OneShardBuffers = std::vector< std::unique_ptr< TypedImportBuffer >>
- Protected Member Functions inherited from import_export::Loader
void init ()
virtual bool loadImpl (const std::vector< std::unique_ptr< TypedImportBuffer >> &import_buffers, size_t row_count, bool checkpoint, const Catalog_Namespace::SessionInfo *session_info)
void 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)
- Protected Attributes inherited from import_export::Loader
const TableDescriptortable_desc_
std::list< const
ColumnDescriptor * > 
LoadCallbackType load_callback_
Fragmenter_Namespace::InsertData insert_data_
std::map< int, StringDictionary * > dict_map_

Detailed Description

Definition at line 23 of file DistributedLoader.h.

Constructor & Destructor Documentation

DistributedLoader::DistributedLoader ( const Catalog_Namespace::SessionInfo parent_session_info,
const TableDescriptor t,
LeafAggregator aggregator 

Definition at line 25 of file DistributedLoader.h.

References CHECK.

28  : Loader(parent_session_info.getCatalog(), t) {
29  CHECK(false);
30  }
Loader(Catalog_Namespace::Catalog &c, const TableDescriptor *t, LoadCallbackType load_callback=nullptr)
Definition: Importer.h:565
Catalog & getCatalog() const
Definition: SessionInfo.h:75
#define CHECK(condition)
Definition: Logger.h:291

Member Function Documentation

bool DistributedLoader::load ( const std::vector< std::unique_ptr< import_export::TypedImportBuffer >> &  import_buffers,
const size_t  row_count,
const Catalog_Namespace::SessionInfo session_info 

Reimplemented from import_export::Loader.

Definition at line 32 of file DistributedLoader.h.

References CHECK.

35  {
36  CHECK(false);
37  return false;
38  }
#define CHECK(condition)
Definition: Logger.h:291

The documentation for this class was generated from the following file: