#include <BaselineHashTable.h>

Inheritance diagram for BaselineHashTable:

Collaboration diagram for BaselineHashTable:

Public Member Functions
	BaselineHashTable (HashType layout, const size_t entry_count, const size_t emitted_keys_count, const size_t hash_table_size)

	BaselineHashTable (Data_Namespace::DataMgr *data_mgr, HashType layout, const size_t entry_count, const size_t emitted_keys_count, const size_t hash_table_size, const size_t device_id)

	~BaselineHashTable () override

int8_t *	getGpuBuffer () const override

size_t	getHashTableBufferSize (const ExecutorDeviceType device_type) const override

int8_t *	getCpuBuffer () override

HashType	getLayout () const override

size_t	getEntryCount () const override

size_t	getEmittedKeysCount () const override

Public Member Functions inherited from HashTable
virtual	~HashTable ()

Private Attributes
std::unique_ptr< int8_t[]>	cpu_hash_table_buff_

size_t	cpu_hash_table_buff_size_

Data_Namespace::AbstractBuffer *	gpu_hash_table_buff_

HashType	layout_

size_t	entry_count_

size_t	emitted_keys_count_

Additional Inherited Members
Static Public Member Functions inherited from HashTable
static DecodedJoinHashBufferSet	toSet (size_t key_component_count, size_t key_component_width, size_t entry_count, const int8_t ptr1, const int8_t ptr2, const int8_t ptr3, const int8_t ptr4, size_t buffer_size)
	Decode hash table into a std::set for easy inspection and validation. More...

static std::string	toString (const std::string &type, const std::string &layout_type, size_t key_component_count, size_t key_component_width, size_t entry_count, const int8_t ptr1, const int8_t ptr2, const int8_t ptr3, const int8_t ptr4, size_t buffer_size, bool raw=false)
	Decode hash table into a human-readable string. More...

Detailed Description

Definition at line 26 of file BaselineHashTable.h.

Constructor & Destructor Documentation

BaselineHashTable::BaselineHashTable	(	HashType	layout,
		const size_t	entry_count,
		const size_t	emitted_keys_count,
		const size_t	hash_table_size
	)

inline

Definition at line 29 of file BaselineHashTable.h.

References cpu_hash_table_buff_, and cpu_hash_table_buff_size_.

       : cpu_hash_table_buff_size_(hash_table_size)
       , gpu_hash_table_buff_(nullptr)
 #ifdef HAVE_CUDA
       , device_id_(0)
       , data_mgr_(nullptr)
 #endif
       , layout_(layout)
       , entry_count_(entry_count)
       , emitted_keys_count_(emitted_keys_count) {
     cpu_hash_table_buff_.reset(new int8_t[cpu_hash_table_buff_size_]);
   }

BaselineHashTable::BaselineHashTable	(	Data_Namespace::DataMgr *	data_mgr,
		HashType	layout,
		const size_t	entry_count,
		const size_t	emitted_keys_count,
		const size_t	hash_table_size,
		const size_t	device_id
	)

inline

Definition at line 46 of file BaselineHashTable.h.

References CudaAllocator::allocGpuAbstractBuffer(), CHECK, data_mgr_(), gpu_hash_table_buff_, and UNREACHABLE.

       : gpu_hash_table_buff_(nullptr)
 #ifdef HAVE_CUDA
       , device_id_(device_id)
       , data_mgr_(data_mgr)
 #endif
       , layout_(layout)
       , entry_count_(entry_count)
       , emitted_keys_count_(emitted_keys_count) {
 #ifdef HAVE_CUDA
     CHECK(data_mgr_);
     gpu_hash_table_buff_ =
         CudaAllocator::allocGpuAbstractBuffer(data_mgr_, hash_table_size, device_id_);
 #else
     UNREACHABLE();
 #endif
   }

Here is the call graph for this function:

BaselineHashTable::~BaselineHashTable ( )

inlineoverride

Definition at line 69 of file BaselineHashTable.h.

References CHECK, data_mgr_(), and gpu_hash_table_buff_.

                                 {
 #ifdef HAVE_CUDA
     if (gpu_hash_table_buff_) {
       CHECK(data_mgr_);
       data_mgr_->free(gpu_hash_table_buff_);
     }
 #endif
   }

Here is the call graph for this function:

Member Function Documentation

int8_t* BaselineHashTable::getCpuBuffer ( )

inlineoverridevirtual

Implements HashTable.

Definition at line 91 of file BaselineHashTable.h.

References cpu_hash_table_buff_.

                                   {
     return reinterpret_cast<int8_t*>(cpu_hash_table_buff_.get());
   }

size_t BaselineHashTable::getEmittedKeysCount ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 97 of file BaselineHashTable.h.

References emitted_keys_count_.

97 { return emitted_keys_count_; }

BaselineHashTable::emitted_keys_count_

size_t emitted_keys_count_

Definition: BaselineHashTable.h:111

size_t BaselineHashTable::getEntryCount ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 96 of file BaselineHashTable.h.

References entry_count_.

96 { return entry_count_; }

BaselineHashTable::entry_count_

size_t entry_count_

Definition: BaselineHashTable.h:110

int8_t* BaselineHashTable::getGpuBuffer ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 78 of file BaselineHashTable.h.

References Data_Namespace::AbstractBuffer::getMemoryPtr(), and gpu_hash_table_buff_.

                                         {
     return gpu_hash_table_buff_ ? gpu_hash_table_buff_->getMemoryPtr() : nullptr;
   }

Here is the call graph for this function:

size_t BaselineHashTable::getHashTableBufferSize ( const ExecutorDeviceType device_type ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 82 of file BaselineHashTable.h.

References CPU, cpu_hash_table_buff_, cpu_hash_table_buff_size_, gpu_hash_table_buff_, and Data_Namespace::AbstractBuffer::reservedSize().

                                                                                      {
     if (device_type == ExecutorDeviceType::CPU) {
       return cpu_hash_table_buff_size_ *
              sizeof(decltype(cpu_hash_table_buff_)::element_type);
     } else {
       return gpu_hash_table_buff_ ? gpu_hash_table_buff_->reservedSize() : 0;
     }
   }