data_conversion::StringViewSource Class Reference

#include <StringViewSource.h>

Inheritance diagram for data_conversion::StringViewSource:

Collaboration diagram for data_conversion::StringViewSource:

Public Member Functions
	StringViewSource (const Chunk_NS::Chunk &input)
std::pair< const int8_t *, size_t >	getSourceData () override
Public Member Functions inherited from data_conversion::BaseSource
virtual	~BaseSource ()=default

Private Attributes
std::vector< std::string_view >	src_string_views_
const Chunk_NS::Chunk &	input_

Detailed Description

Definition at line 89 of file StringViewSource.h.

Constructor & Destructor Documentation

data_conversion::StringViewSource::StringViewSource ( const Chunk_NS::Chunk &  input )

inline

Definition at line 91 of file StringViewSource.h.

: input_(input) {}

Member Function Documentation

std::pair<const int8_t*, size_t> data_conversion::StringViewSource::getSourceData ( )

inlineoverridevirtual

Implements data_conversion::BaseSource.

Definition at line 93 of file StringViewSource.h.

References CHECK, ColumnDescriptor::columnType, data_conversion::anonymous_namespace{StringViewSource.h}::get_materialized_string_views(), Chunk_NS::Chunk::getBuffer(), Catalog_Namespace::SysCatalog::getCatalog(), Chunk_NS::Chunk::getColumnDesc(), Chunk_NS::Chunk::getIndexBuf(), StringNoneEncoder::getStringAtIndex(), SQLTypeInfo::getStringDictKey(), input_, Catalog_Namespace::SysCatalog::instance(), src_string_views_, and UNREACHABLE.

                                                          {
    auto buffer = input_.getBuffer();
    auto src_type_info = input_.getColumnDesc()->columnType;
    auto dict_key = src_type_info.getStringDictKey();
    auto num_elements = buffer->getEncoder()->getNumElems();

    if (src_type_info.is_dict_encoded_string()) {
      auto catalog = Catalog_Namespace::SysCatalog::instance().getCatalog(dict_key.db_id);

      auto src_string_dictionary =
          catalog->getMetadataForDict(dict_key.dict_id, true)->stringDict.get();
      CHECK(src_string_dictionary);
      src_string_views_ = get_materialized_string_views(
          num_elements, src_string_dictionary, buffer->getMemoryPtr(), src_type_info);
    } else if (src_type_info.is_none_encoded_string()) {
      auto index_buffer = input_.getIndexBuf();
      src_string_views_.resize(num_elements);
      for (size_t i = 0; i < num_elements; ++i) {
        src_string_views_[i] = StringNoneEncoder::getStringAtIndex(
            index_buffer->getMemoryPtr(), buffer->getMemoryPtr(), i);
      }
    } else {
      UNREACHABLE() << "unknown string type";
    }

    return {reinterpret_cast<int8_t*>(src_string_views_.data()), num_elements};
  }

Here is the call graph for this function:

Member Data Documentation

const Chunk_NS::Chunk& data_conversion::StringViewSource::input_

private

Definition at line 124 of file StringViewSource.h.

Referenced by getSourceData().

std::vector<std::string_view> data_conversion::StringViewSource::src_string_views_

private

Definition at line 122 of file StringViewSource.h.

Referenced by getSourceData().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/DataMgr/DataConversion/StringViewSource.h