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::Catalog &	getCatalog () const

const TableDescriptor *	getTableDesc () const

const std::list< const ColumnDescriptor * > &	get_column_descs () const

StringDictionary *	getStringDict (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
Catalog_Namespace::Catalog &	catalog_

const TableDescriptor *	table_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	(	const Catalog_Namespace::SessionInfo &	parent_session_info,
		const TableDescriptor *	t,
		LeafAggregator *	aggregator
	)

inline

Definition at line 25 of file DistributedLoader.h.

References CHECK.

       : Loader(parent_session_info.getCatalog(), t) {
     CHECK(false);
   }

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
	)

inlineoverridevirtual

Definition at line 32 of file DistributedLoader.h.

References CHECK.

                                                                        {
     CHECK(false);
     return false;
   }

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

/home/jenkins-slave/workspace/core-os-doxygen/Distributed/os/DistributedLoader.h