OmniSciDB  baf940c279
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) override
- Public Member Functions inherited from import_export::Loader
 Loader (Catalog_Namespace::Catalog &c, const TableDescriptor *t, LoadCallbackType load_callback=nullptr, bool use_catalog_locks=true)
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)
virtual void checkpoint ()
virtual std::vector< Catalog_Namespace::TableEpochInfogetTableEpochs () const
virtual void setTableEpochs (const std::vector< Catalog_Namespace::TableEpochInfo > &table_epochs)
void setReplicating (const bool replicating)
bool getReplicating () const
void dropColumns (const std::vector< int > &columns)

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 (const bool use_catalog_locks)
virtual bool loadImpl (const std::vector< std::unique_ptr< TypedImportBuffer >> &import_buffers, size_t row_count, bool checkpoint)
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)
- Protected Attributes inherited from import_export::Loader
const TableDescriptortable_desc_
std::list< const ColumnDescriptor * > column_descs_
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::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, bool use_catalog_locks=true)
Definition: Importer.h:523
Catalog & getCatalog() const
Definition: SessionInfo.h:65
#define CHECK(condition)
Definition: Logger.h:197

Member Function Documentation

◆ load()

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

Reimplemented from import_export::Loader.

Definition at line 32 of file DistributedLoader.h.

References CHECK.

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

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