#include <PerfectHashTable.h>

Inheritance diagram for PerfectHashTable:

Collaboration diagram for PerfectHashTable:

Public Member Functions
	PerfectHashTable (Data_Namespace::DataMgr *data_mgr, const HashType layout, const ExecutorDeviceType device_type, const size_t entry_count, const size_t emitted_keys_count, const bool for_window_framing=false)

	~PerfectHashTable () override

size_t	gpuReservedSize () const

void	allocateGpuMemory (const size_t entries, const int device_id)

size_t	getHashTableBufferSize (const ExecutorDeviceType device_type) const override

HashType	getLayout () const override

int8_t *	getCpuBuffer () override

int8_t *	getGpuBuffer () const override

size_t	getEntryCount () const override

size_t	getEmittedKeysCount () const override

void	setHashEntryInfo (BucketizedHashEntryInfo &hash_entry_info)

void	setColumnNumElems (size_t elem)

BucketizedHashEntryInfo	getHashEntryInfo () const

size_t	getColumnNumElems () const

Public Member Functions inherited from HashTable
virtual	~HashTable ()

Private Attributes
Data_Namespace::AbstractBuffer *	gpu_hash_table_buff_ {nullptr}

Data_Namespace::DataMgr *	data_mgr_

std::unique_ptr< int32_t[]>	cpu_hash_table_buff_

size_t	cpu_hash_table_buff_size_

HashType	layout_

size_t	entry_count_

size_t	emitted_keys_count_

BucketizedHashEntryInfo	hash_entry_info_

size_t	column_num_elems_

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 25 of file PerfectHashTable.h.

Constructor & Destructor Documentation

PerfectHashTable::PerfectHashTable	(	Data_Namespace::DataMgr *	data_mgr,
		const HashType	layout,
		const ExecutorDeviceType	device_type,
		const size_t	entry_count,
		const size_t	emitted_keys_count,
		const bool	for_window_framing = `false`
	)

inline

Definition at line 28 of file PerfectHashTable.h.

References CPU, cpu_hash_table_buff_, cpu_hash_table_buff_size_, emitted_keys_count_, entry_count_, layout_, OneToOne, HashTable::toString(), and VLOG.

       : data_mgr_(data_mgr)
       , layout_(layout)
       , entry_count_(entry_count)
       , emitted_keys_count_(emitted_keys_count) {
     std::string device_str = "GPU";
     if (device_type == ExecutorDeviceType::CPU) {
       device_str = "CPU";
       cpu_hash_table_buff_size_ =
           layout_ == HashType::OneToOne
               ? entry_count_
               : 2 * entry_count_ + ((1 + for_window_framing) * emitted_keys_count_);
       cpu_hash_table_buff_.reset(new int32_t[cpu_hash_table_buff_size_]);
     }
     VLOG(1) << "Initialize a " << device_str << " perfect hash table for join type "
             << ::toString(layout) << " # hash entries: " << entry_count
             << ", # entries stored in the payload buffer: " << emitted_keys_count
             << ", hash table size : " << cpu_hash_table_buff_size_ * 4 << " Bytes";
   }

Here is the call graph for this function:

PerfectHashTable::~PerfectHashTable ( )

inlineoverride

Definition at line 53 of file PerfectHashTable.h.

References CHECK, data_mgr_, Data_Namespace::DataMgr::free(), and gpu_hash_table_buff_.

                                {
     if (gpu_hash_table_buff_) {
       CHECK(data_mgr_);
       data_mgr_->free(gpu_hash_table_buff_);
     }
   }

Here is the call graph for this function:

Member Function Documentation

void PerfectHashTable::allocateGpuMemory	(	const size_t	entries,
		const int	device_id
	)

inline

Definition at line 65 of file PerfectHashTable.h.

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

                                                                     {
     CHECK_GE(device_id, 0);
     CHECK(!gpu_hash_table_buff_);
     gpu_hash_table_buff_ = CudaAllocator::allocGpuAbstractBuffer(
         data_mgr_, entries * sizeof(int32_t), device_id);
   }

Here is the call graph for this function:

size_t PerfectHashTable::getColumnNumElems ( ) const

inline

Definition at line 103 of file PerfectHashTable.h.

References column_num_elems_.

103 { return column_num_elems_; }

PerfectHashTable::column_num_elems_

size_t column_num_elems_

Definition: PerfectHashTable.h:116

int8_t* PerfectHashTable::getCpuBuffer ( )

inlineoverridevirtual

Implements HashTable.

Definition at line 83 of file PerfectHashTable.h.

References cpu_hash_table_buff_.

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

size_t PerfectHashTable::getEmittedKeysCount ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 93 of file PerfectHashTable.h.

References emitted_keys_count_.

93 { return emitted_keys_count_; }

PerfectHashTable::emitted_keys_count_

size_t emitted_keys_count_

Definition: PerfectHashTable.h:113

size_t PerfectHashTable::getEntryCount ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 91 of file PerfectHashTable.h.

References entry_count_.

91 { return entry_count_; }

PerfectHashTable::entry_count_

size_t entry_count_

Definition: PerfectHashTable.h:112

int8_t* PerfectHashTable::getGpuBuffer ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 87 of file PerfectHashTable.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:

BucketizedHashEntryInfo PerfectHashTable::getHashEntryInfo ( ) const

inline

Definition at line 101 of file PerfectHashTable.h.

References hash_entry_info_.

101 { return hash_entry_info_; }

PerfectHashTable::hash_entry_info_

BucketizedHashEntryInfo hash_entry_info_

Definition: PerfectHashTable.h:115

size_t PerfectHashTable::getHashTableBufferSize ( const ExecutorDeviceType device_type ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 72 of file PerfectHashTable.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;
     }
   }

Here is the call graph for this function:

HashType PerfectHashTable::getLayout ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 81 of file PerfectHashTable.h.

References layout_.

81 { return layout_; }

PerfectHashTable::layout_

HashType layout_

Definition: PerfectHashTable.h:111

size_t PerfectHashTable::gpuReservedSize ( ) const

inline

Definition at line 60 of file PerfectHashTable.h.

References CHECK, gpu_hash_table_buff_, and Data_Namespace::AbstractBuffer::reservedSize().

                                  {
     CHECK(gpu_hash_table_buff_);
     return gpu_hash_table_buff_->reservedSize();
   }

Here is the call graph for this function:

void PerfectHashTable::setColumnNumElems ( size_t elem )

inline

Definition at line 99 of file PerfectHashTable.h.

References column_num_elems_.

99 { column_num_elems_ = elem; }

PerfectHashTable::column_num_elems_

size_t column_num_elems_

Definition: PerfectHashTable.h:116

void PerfectHashTable::setHashEntryInfo ( BucketizedHashEntryInfo & hash_entry_info )

inline

Definition at line 95 of file PerfectHashTable.h.

References hash_entry_info_.

                                                                   {
     hash_entry_info_ = hash_entry_info;
   }

Member Data Documentation

size_t PerfectHashTable::column_num_elems_

private

Definition at line 116 of file PerfectHashTable.h.

Referenced by getColumnNumElems(), and setColumnNumElems().

std::unique_ptr<int32_t[]> PerfectHashTable::cpu_hash_table_buff_

private

Definition at line 108 of file PerfectHashTable.h.

Referenced by getCpuBuffer(), getHashTableBufferSize(), and PerfectHashTable().

size_t PerfectHashTable::cpu_hash_table_buff_size_

private

Definition at line 109 of file PerfectHashTable.h.

Referenced by getHashTableBufferSize(), and PerfectHashTable().

Data_Namespace::DataMgr* PerfectHashTable::data_mgr_

private

Definition at line 107 of file PerfectHashTable.h.

Referenced by allocateGpuMemory(), and ~PerfectHashTable().

size_t PerfectHashTable::emitted_keys_count_

private

Definition at line 113 of file PerfectHashTable.h.

Referenced by getEmittedKeysCount(), and PerfectHashTable().

size_t PerfectHashTable::entry_count_

private

Definition at line 112 of file PerfectHashTable.h.

Referenced by getEntryCount(), and PerfectHashTable().

Data_Namespace::AbstractBuffer* PerfectHashTable::gpu_hash_table_buff_ {nullptr}

private

Definition at line 106 of file PerfectHashTable.h.

Referenced by allocateGpuMemory(), getGpuBuffer(), getHashTableBufferSize(), gpuReservedSize(), and ~PerfectHashTable().

BucketizedHashEntryInfo PerfectHashTable::hash_entry_info_

private

Definition at line 115 of file PerfectHashTable.h.

Referenced by getHashEntryInfo(), and setHashEntryInfo().

HashType PerfectHashTable::layout_

private

Definition at line 111 of file PerfectHashTable.h.

Referenced by getLayout(), and PerfectHashTable().

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

/home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/JoinHashTable/PerfectHashTable.h

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation