RowSetMemoryOwner Class Reference

#include <RowSetMemoryOwner.h>

Inheritance diagram for RowSetMemoryOwner:

Collaboration diagram for RowSetMemoryOwner:

Classes
struct	CountDistinctBitmapBuffer

Public Member Functions
void	addCountDistinctBuffer (int8_t *count_distinct_buffer, const size_t bytes, const bool system_allocated)
void	addCountDistinctSet (std::set< int64_t > *count_distinct_set)
void	addGroupByBuffer (int64_t *group_by_buffer)
void	addVarlenBuffer (void *varlen_buffer)
std::string *	addString (const std::string &str)
std::vector< int64_t > *	addArray (const std::vector< int64_t > &arr)
StringDictionaryProxy *	addStringDict (std::shared_ptr< StringDictionary > str_dict, const int dict_id, const ssize_t generation)
StringDictionaryProxy *	getStringDictProxy (const int dict_id) const
void	addLiteralStringDictProxy (std::shared_ptr< StringDictionaryProxy > lit_str_dict_proxy)
StringDictionaryProxy *	getLiteralStringDictProxy () const
void	addColBuffer (const void *col_buffer)
	~RowSetMemoryOwner ()

Private Attributes
std::vector < CountDistinctBitmapBuffer >	count_distinct_bitmaps_
std::vector< std::set< int64_t > * >	count_distinct_sets_
std::vector< int64_t * >	group_by_buffers_
std::vector< void * >	varlen_buffers_
std::list< std::string >	strings_
std::list< std::vector< int64_t > >	arrays_
std::unordered_map< int, StringDictionaryProxy * >	str_dict_proxy_owned_
std::shared_ptr < StringDictionaryProxy >	lit_str_dict_proxy_
std::vector< void * >	col_buffers_
std::mutex	state_mutex_

Friends
class	ResultSet

Detailed Description

Definition at line 33 of file RowSetMemoryOwner.h.

Constructor & Destructor Documentation

RowSetMemoryOwner::~RowSetMemoryOwner ( )

inline

Definition at line 109 of file RowSetMemoryOwner.h.

References col_buffers_, count_distinct_bitmaps_, count_distinct_sets_, group_by_buffers_, str_dict_proxy_owned_, and varlen_buffers_.

                       {
    for (const auto& count_distinct_buffer : count_distinct_bitmaps_) {
      if (count_distinct_buffer.system_allocated) {
        free(count_distinct_buffer.ptr);
      }
    }
    for (auto count_distinct_set : count_distinct_sets_) {
      delete count_distinct_set;
    }
    for (auto group_by_buffer : group_by_buffers_) {
      free(group_by_buffer);
    }
    for (auto varlen_buffer : varlen_buffers_) {
      free(varlen_buffer);
    }
    for (auto col_buffer : col_buffers_) {
      free(col_buffer);
    }

    for (auto dict_proxy : str_dict_proxy_owned_) {
      delete dict_proxy.second;
    }
  }

Member Function Documentation

std::vector<int64_t>* RowSetMemoryOwner::addArray ( const std::vector< int64_t > &  arr )

inline

Definition at line 64 of file RowSetMemoryOwner.h.

References arrays_, and state_mutex_.

                                                              {
    std::lock_guard<std::mutex> lock(state_mutex_);
    arrays_.emplace_back(arr);
    return &arrays_.back();
  }

void RowSetMemoryOwner::addColBuffer ( const void *  col_buffer )

inline

Definition at line 104 of file RowSetMemoryOwner.h.

References col_buffers_, and state_mutex_.

Referenced by JoinHashTable::getAllColumnFragments(), and BaselineJoinHashTable::getAllColumnFragments().

                                            {
    std::lock_guard<std::mutex> lock(state_mutex_);
    col_buffers_.push_back(const_cast<void*>(col_buffer));
  }

Here is the caller graph for this function:

void RowSetMemoryOwner::addCountDistinctBuffer ( int8_t *  count_distinct_buffer, const size_t  bytes, const bool  system_allocated  )

inline

Definition at line 35 of file RowSetMemoryOwner.h.

References count_distinct_bitmaps_, and state_mutex_.

                                                           {
    std::lock_guard<std::mutex> lock(state_mutex_);
    count_distinct_bitmaps_.emplace_back(
        CountDistinctBitmapBuffer{count_distinct_buffer, bytes, system_allocated});
  }

void RowSetMemoryOwner::addCountDistinctSet ( std::set< int64_t > *  count_distinct_set )

inline

Definition at line 43 of file RowSetMemoryOwner.h.

References count_distinct_sets_, and state_mutex_.

                                                                {
    std::lock_guard<std::mutex> lock(state_mutex_);
    count_distinct_sets_.push_back(count_distinct_set);
  }

void RowSetMemoryOwner::addGroupByBuffer ( int64_t *  group_by_buffer )

inline

Definition at line 48 of file RowSetMemoryOwner.h.

References group_by_buffers_, and state_mutex_.

                                                  {
    std::lock_guard<std::mutex> lock(state_mutex_);
    group_by_buffers_.push_back(group_by_buffer);
  }

void RowSetMemoryOwner::addLiteralStringDictProxy ( std::shared_ptr< StringDictionaryProxy >  lit_str_dict_proxy )

inline

Definition at line 93 of file RowSetMemoryOwner.h.

References lit_str_dict_proxy_, and state_mutex_.

                                                               {
    std::lock_guard<std::mutex> lock(state_mutex_);
    lit_str_dict_proxy_ = lit_str_dict_proxy;
  }

std::string* RowSetMemoryOwner::addString ( const std::string &  str )

inline

Definition at line 58 of file RowSetMemoryOwner.h.

References state_mutex_, and strings_.

                                             {
    std::lock_guard<std::mutex> lock(state_mutex_);
    strings_.emplace_back(str);
    return &strings_.back();
  }

StringDictionaryProxy* RowSetMemoryOwner::addStringDict ( std::shared_ptr< StringDictionary >  str_dict, const int  dict_id, const ssize_t  generation  )

inline

Definition at line 70 of file RowSetMemoryOwner.h.

References CHECK_EQ, state_mutex_, and str_dict_proxy_owned_.

                                                                 {
    std::lock_guard<std::mutex> lock(state_mutex_);
    auto it = str_dict_proxy_owned_.find(dict_id);
    if (it != str_dict_proxy_owned_.end()) {
      CHECK_EQ(it->second->getDictionary(), str_dict.get());
      it->second->updateGeneration(generation);
      return it->second;
    }
    StringDictionaryProxy* str_dict_proxy =
        new StringDictionaryProxy(str_dict, generation);
    str_dict_proxy_owned_.emplace(dict_id, str_dict_proxy);
    return str_dict_proxy;
  }

void RowSetMemoryOwner::addVarlenBuffer ( void *  varlen_buffer )

inline

Definition at line 53 of file RowSetMemoryOwner.h.

References state_mutex_, and varlen_buffers_.

                                            {
    std::lock_guard<std::mutex> lock(state_mutex_);
    varlen_buffers_.push_back(varlen_buffer);
  }

StringDictionaryProxy* RowSetMemoryOwner::getLiteralStringDictProxy ( ) const

inline

Definition at line 99 of file RowSetMemoryOwner.h.

References lit_str_dict_proxy_, and state_mutex_.

                                                           {
    std::lock_guard<std::mutex> lock(state_mutex_);
    return lit_str_dict_proxy_.get();
  }

StringDictionaryProxy* RowSetMemoryOwner::getStringDictProxy ( const int  dict_id ) const

inline

Definition at line 86 of file RowSetMemoryOwner.h.

References CHECK(), state_mutex_, and str_dict_proxy_owned_.

                                                                     {
    std::lock_guard<std::mutex> lock(state_mutex_);
    auto it = str_dict_proxy_owned_.find(dict_id);
    CHECK(it != str_dict_proxy_owned_.end());
    return it->second;
  }

Here is the call graph for this function:

Friends And Related Function Documentation

friend class ResultSet

friend

Definition at line 151 of file RowSetMemoryOwner.h.

Member Data Documentation

std::list<std::vector<int64_t> > RowSetMemoryOwner::arrays_

private

Definition at line 145 of file RowSetMemoryOwner.h.

Referenced by addArray().

std::vector<void*> RowSetMemoryOwner::col_buffers_

private

Definition at line 148 of file RowSetMemoryOwner.h.

Referenced by addColBuffer(), and ~RowSetMemoryOwner().

std::vector<CountDistinctBitmapBuffer> RowSetMemoryOwner::count_distinct_bitmaps_

private

Definition at line 140 of file RowSetMemoryOwner.h.

Referenced by addCountDistinctBuffer(), and ~RowSetMemoryOwner().

std::vector<std::set<int64_t>*> RowSetMemoryOwner::count_distinct_sets_

private

Definition at line 141 of file RowSetMemoryOwner.h.

Referenced by addCountDistinctSet(), and ~RowSetMemoryOwner().

std::vector<int64_t*> RowSetMemoryOwner::group_by_buffers_

private

Definition at line 142 of file RowSetMemoryOwner.h.

Referenced by addGroupByBuffer(), and ~RowSetMemoryOwner().

std::shared_ptr<StringDictionaryProxy> RowSetMemoryOwner::lit_str_dict_proxy_

private

Definition at line 147 of file RowSetMemoryOwner.h.

Referenced by addLiteralStringDictProxy(), and getLiteralStringDictProxy().

std::mutex RowSetMemoryOwner::state_mutex_

mutableprivate

Definition at line 149 of file RowSetMemoryOwner.h.

Referenced by addArray(), addColBuffer(), addCountDistinctBuffer(), addCountDistinctSet(), addGroupByBuffer(), addLiteralStringDictProxy(), addString(), addStringDict(), addVarlenBuffer(), getLiteralStringDictProxy(), and getStringDictProxy().

std::unordered_map<int, StringDictionaryProxy*> RowSetMemoryOwner::str_dict_proxy_owned_

private

Definition at line 146 of file RowSetMemoryOwner.h.

Referenced by addStringDict(), getStringDictProxy(), and ~RowSetMemoryOwner().

std::list<std::string> RowSetMemoryOwner::strings_

private

Definition at line 144 of file RowSetMemoryOwner.h.

Referenced by addString().

std::vector<void*> RowSetMemoryOwner::varlen_buffers_

private

Definition at line 143 of file RowSetMemoryOwner.h.

Referenced by addVarlenBuffer(), and ~RowSetMemoryOwner().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/Descriptors/RowSetMemoryOwner.h