BaselineHashTable Class Reference

#include <BaselineHashTable.h>

Inheritance diagram for BaselineHashTable:

Collaboration diagram for BaselineHashTable:

Public Member Functions
	BaselineHashTable (MemoryLevel memory_level, BaselineHashTableEntryInfo hash_table_entry_info, Data_Namespace::DataMgr *data_mgr=nullptr, const int device_id=-1)
	~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
size_t	getRowIdSize () const override
BaselineHashTableEntryInfo	getHashTableEntryInfo () const
Public Member Functions inherited from HashTable
virtual	~HashTable ()

Private Attributes
std::unique_ptr< int8_t[]>	cpu_hash_table_buff_
Data_Namespace::AbstractBuffer *	gpu_hash_table_buff_ {nullptr}
MemoryLevel	memory_level_
BaselineHashTableEntryInfo	hash_table_entry_info_
Data_Namespace::DataMgr *	data_mgr_
const int	device_id_

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 70 of file BaselineHashTable.h.

Constructor & Destructor Documentation

BaselineHashTable::BaselineHashTable ( MemoryLevel  memory_level, BaselineHashTableEntryInfo  hash_table_entry_info, Data_Namespace::DataMgr *  data_mgr = nullptr, const int  device_id = -1  )

inline

Definition at line 73 of file BaselineHashTable.h.

References CudaAllocator::allocGpuAbstractBuffer(), CHECK, CHECK_GE, BaselineHashTableEntryInfo::computeHashTableSize(), cpu_hash_table_buff_, data_mgr_, device_id_, HashTableEntryInfo::getHashTableLayout(), HashTableEntryInfo::getNumHashEntries(), HashTableEntryInfo::getNumKeys(), HashTableEntryInfo::getRowIdSizeInBytes(), gpu_hash_table_buff_, Data_Namespace::GPU_LEVEL, hash_table_entry_info_, memory_level_, OneToOne, UNREACHABLE, and VLOG.

      : memory_level_(memory_level)
      , hash_table_entry_info_(hash_table_entry_info)
      , data_mgr_(data_mgr)
      , device_id_(device_id) {
    auto const hash_table_size = hash_table_entry_info.computeHashTableSize();
    if (memory_level_ == Data_Namespace::GPU_LEVEL) {
#ifdef HAVE_CUDA
      CHECK(data_mgr_);
      gpu_hash_table_buff_ =
          CudaAllocator::allocGpuAbstractBuffer(data_mgr_, hash_table_size, device_id_);
#else
      UNREACHABLE();
#endif
    } else {
      CHECK(!data_mgr_);  // we do not need `data_mgr` for CPU hash table
      cpu_hash_table_buff_.reset(new int8_t[hash_table_size]);
    }
    std::string device_str = memory_level_ == MemoryLevel::GPU_LEVEL ? "GPU" : "CPU";
    std::string layout_str =
        hash_table_entry_info_.getHashTableLayout() == HashType::OneToOne ? "OneToOne"
                                                                          : "OneToMany";
    std::ostringstream oss;
    oss << "Initialize a " << device_str << " baseline hash table";
    if (memory_level_ == MemoryLevel::GPU_LEVEL) {
      CHECK_GE(device_id, 0);
      oss << " for device " << device_id_;
    }
    oss << " with join type " << layout_str << ", hash table size: " << hash_table_size
        << " Bytes"
        << ", # hash entries: " << hash_table_entry_info_.getNumHashEntries()
        << ", # entries stored in the payload buffer: "
        << hash_table_entry_info_.getNumKeys()
        << ", rowid size: " << hash_table_entry_info_.getRowIdSizeInBytes() << " Bytes";
    VLOG(1) << oss.str();
  }

Here is the call graph for this function:

BaselineHashTable::~BaselineHashTable ( )

inlineoverride

Definition at line 113 of file BaselineHashTable.h.

References CHECK, data_mgr_, Data_Namespace::DataMgr::free(), 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 130 of file BaselineHashTable.h.

References cpu_hash_table_buff_.

                                  {
    return cpu_hash_table_buff_.get();
  }

size_t BaselineHashTable::getEmittedKeysCount ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 140 of file BaselineHashTable.h.

References HashTableEntryInfo::getNumKeys(), and hash_table_entry_info_.

                                              {
    return hash_table_entry_info_.getNumKeys();
  }

Here is the call graph for this function:

size_t BaselineHashTable::getEntryCount ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 137 of file BaselineHashTable.h.

References HashTableEntryInfo::getNumHashEntries(), and hash_table_entry_info_.

                                        {
    return hash_table_entry_info_.getNumHashEntries();
  }

Here is the call graph for this function:

int8_t* BaselineHashTable::getGpuBuffer ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 122 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 126 of file BaselineHashTable.h.

References BaselineHashTableEntryInfo::computeHashTableSize(), and hash_table_entry_info_.

                                                                                     {
    return hash_table_entry_info_.computeHashTableSize();
  }

Here is the call graph for this function:

BaselineHashTableEntryInfo BaselineHashTable::getHashTableEntryInfo ( ) const

inline

Definition at line 146 of file BaselineHashTable.h.

References hash_table_entry_info_.

                                                           {
    return hash_table_entry_info_;
  }

HashType BaselineHashTable::getLayout ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 134 of file BaselineHashTable.h.

References HashTableEntryInfo::getHashTableLayout(), and hash_table_entry_info_.

                                      {
    return hash_table_entry_info_.getHashTableLayout();
  }

Here is the call graph for this function:

size_t BaselineHashTable::getRowIdSize ( ) const

inlineoverridevirtual

Implements HashTable.

Definition at line 143 of file BaselineHashTable.h.

References HashTableEntryInfo::getRowIdSizeInBytes(), and hash_table_entry_info_.

                                       {
    return hash_table_entry_info_.getRowIdSizeInBytes();
  }

Here is the call graph for this function:

Member Data Documentation

std::unique_ptr<int8_t[]> BaselineHashTable::cpu_hash_table_buff_

private

Definition at line 151 of file BaselineHashTable.h.

Referenced by BaselineHashTable(), and getCpuBuffer().

Data_Namespace::DataMgr* BaselineHashTable::data_mgr_

private

Definition at line 156 of file BaselineHashTable.h.

Referenced by BaselineHashTable(), and ~BaselineHashTable().

const int BaselineHashTable::device_id_

private

Definition at line 157 of file BaselineHashTable.h.

Referenced by BaselineHashTable().

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

private

Definition at line 152 of file BaselineHashTable.h.

Referenced by BaselineHashTable(), getGpuBuffer(), and ~BaselineHashTable().

BaselineHashTableEntryInfo BaselineHashTable::hash_table_entry_info_

private

Definition at line 155 of file BaselineHashTable.h.

Referenced by BaselineHashTable(), getEmittedKeysCount(), getEntryCount(), getHashTableBufferSize(), getHashTableEntryInfo(), getLayout(), and getRowIdSize().

MemoryLevel BaselineHashTable::memory_level_

private

Definition at line 154 of file BaselineHashTable.h.

Referenced by BaselineHashTable().

---

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

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