OmniSciDB  1dac507f6e
 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
 

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
Catalog_Namespace::Catalogcatalog_
 
const TableDescriptortable_desc_
 
std::list< const
ColumnDescriptor * > 
column_descs_
 
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 
)
inline

Definition at line 25 of file DistributedLoader.h.

References CHECK().

28  : Loader(parent_session_info.getCatalog(), t) {
29  CHECK(false);
30  }
CHECK(cgen_state)
Loader(Catalog_Namespace::Catalog &c, const TableDescriptor *t)
Definition: Importer.h:539
Catalog & getCatalog() const
Definition: SessionInfo.h:90

+ 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 
)
inlineoverridevirtual

Reimplemented from Importer_NS::Loader.

Definition at line 32 of file DistributedLoader.h.

References CHECK().

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

+ Here is the call graph for this function:


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