OmniSciDB  cecceef8da
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros 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< Importer_NS::TypedImportBuffer >> &import_buffers, const size_t row_count) override
- Public Member Functions inherited from Importer_NS::Loader
 Loader (Catalog_Namespace::Catalog &c, const TableDescriptor *t)
virtual ~Loader ()
Catalog_Namespace::CataloggetCatalog ()
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 int32_t getTableEpoch ()
virtual void setTableEpoch (const int32_t new_epoch)
void setReplicating (const bool replicating)
bool getReplicating () const
void dropColumns (const std::vector< int > &columns)

Additional Inherited Members

- Protected Types inherited from Importer_NS::Loader
using OneShardBuffers = std::vector< std::unique_ptr< TypedImportBuffer >>
- Protected Member Functions inherited from Importer_NS::Loader
void init ()
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 Importer_NS::Loader
const TableDescriptortable_desc_
std::list< const
ColumnDescriptor * > 
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)
Definition: Importer.h:513
Catalog & getCatalog() const
Definition: SessionInfo.h:76

+ Here is the call graph for this function:

Member Function Documentation

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

Reimplemented from Importer_NS::Loader.

Definition at line 32 of file DistributedLoader.h.

References CHECK().

34  {
35  CHECK(false);
36  return false;
37  }

+ Here is the call graph for this function:

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