#include <heavydbTypes.h>

Collaboration diagram for RowFunctionManager:

Public Member Functions
std::string	getString (int32_t db_id, int32_t dict_id, int32_t string_id)

int32_t	getDictDbId (const char *func_name, size_t arg_idx)

int32_t	getDictId (const char *func_name, size_t arg_idx)

int32_t	getOrAddTransient (int32_t db_id, int32_t dict_id, std::string str)

int8_t *	makeBuffer (int64_t element_count, int64_t element_size)

	RowFunctionManager (const Executor *executor, const RelAlgExecutionUnit &ra_exe_unit)

std::string	getString (int32_t db_id, int32_t dict_id, int32_t string_id)

int32_t	getDictDbId (const std::string &func_name, size_t arg_idx)

int32_t	getDictId (const std::string &func_name, size_t arg_idx)

int32_t	getOrAddTransient (int32_t db_id, int32_t dict_id, std::string str)

int8_t *	getStringDictionaryProxy (int32_t db_id, int32_t dict_id)

int8_t *	makeBuffer (int64_t element_count, int64_t element_size)

Public Attributes
const Executor *	executor_

const RelAlgExecutionUnit &	ra_exe_unit_

Detailed Description

Definition at line 298 of file heavydbTypes.h.

Constructor & Destructor Documentation

RowFunctionManager::RowFunctionManager	(	const Executor *	executor,
		const RelAlgExecutionUnit &	ra_exe_unit
	)

inline

Definition at line 59 of file RowFunctionManager.h.

60 : executor_(executor), ra_exe_unit_(ra_exe_unit) {}

RowFunctionManager::executor_

const Executor * executor_

Definition: RowFunctionManager.h:124

RowFunctionManager::ra_exe_unit_

const RelAlgExecutionUnit & ra_exe_unit_

Definition: RowFunctionManager.h:125

Member Function Documentation

int32_t RowFunctionManager::getDictDbId	(	const std::string &	func_name,
		size_t	arg_idx
	)

inline

Definition at line 68 of file RowFunctionManager.h.

References CHECK, CHECK_LT, anonymous_namespace{RowFunctionManager.h}::drop_suffix_impl(), anonymous_namespace{RowFunctionManager.h}::find_function_oper(), Analyzer::Expr::get_type_info(), Analyzer::FunctionOper::getArg(), Analyzer::FunctionOper::getArity(), ra_exe_unit_, RelAlgExecutionUnit::target_exprs, and UNREACHABLE.

                                                                          {
     std::string func_name_wo_suffix =
         boost::algorithm::to_lower_copy(drop_suffix_impl(func_name));
 
     for (const auto& expr : ra_exe_unit_.target_exprs) {
       for (const auto* op : find_function_oper(expr, func_name_wo_suffix)) {
         const Analyzer::FunctionOper* function_oper =
             dynamic_cast<const Analyzer::FunctionOper*>(op);
         CHECK_LT(arg_idx, function_oper->getArity());
         const SQLTypeInfo typ = function_oper->getArg(arg_idx)->get_type_info();
         CHECK(typ.is_text_encoding_dict() || typ.is_text_encoding_dict_array());
         return typ.getStringDictKey().db_id;
       }
     }
     UNREACHABLE();
     return 0;
   }

Here is the call graph for this function:

int32_t RowFunctionManager::getDictDbId	(	const char *	func_name,
		size_t	arg_idx
	)

inline

Definition at line 304 of file heavydbTypes.h.

References RowFunctionManager_getDictDbId().

                                                              {
     return RowFunctionManager_getDictDbId(
         reinterpret_cast<int8_t*>(this), func_name, arg_idx);
   }

Here is the call graph for this function:

int32_t RowFunctionManager::getDictId	(	const std::string &	func_name,
		size_t	arg_idx
	)

inline

Definition at line 86 of file RowFunctionManager.h.

References CHECK, CHECK_LT, anonymous_namespace{RowFunctionManager.h}::drop_suffix_impl(), anonymous_namespace{RowFunctionManager.h}::find_function_oper(), Analyzer::Expr::get_type_info(), Analyzer::FunctionOper::getArg(), Analyzer::FunctionOper::getArity(), ra_exe_unit_, RelAlgExecutionUnit::target_exprs, and UNREACHABLE.

                                                                        {
     std::string func_name_wo_suffix =
         boost::algorithm::to_lower_copy(drop_suffix_impl(func_name));
 
     for (const auto& expr : ra_exe_unit_.target_exprs) {
       for (const auto* op : find_function_oper(expr, func_name_wo_suffix)) {
         const Analyzer::FunctionOper* function_oper =
             dynamic_cast<const Analyzer::FunctionOper*>(op);
         CHECK_LT(arg_idx, function_oper->getArity());
         const SQLTypeInfo typ = function_oper->getArg(arg_idx)->get_type_info();
         CHECK(typ.is_text_encoding_dict() || typ.is_text_encoding_dict_array());
         return typ.getStringDictKey().dict_id;
       }
     }
     UNREACHABLE();
     return 0;
   }

Here is the call graph for this function:

int32_t RowFunctionManager::getDictId	(	const char *	func_name,
		size_t	arg_idx
	)

inline

Definition at line 309 of file heavydbTypes.h.

References RowFunctionManager_getDictId().

                                                            {
     return RowFunctionManager_getDictId(
         reinterpret_cast<int8_t*>(this), func_name, arg_idx);
   }

Here is the call graph for this function:

int32_t RowFunctionManager::getOrAddTransient	(	int32_t	db_id,
		int32_t	dict_id,
		std::string	str
	)

inline

Definition at line 104 of file RowFunctionManager.h.

References executor_.

                                                                                   {
     const auto proxy = executor_->getStringDictionaryProxy(
         {db_id, dict_id}, executor_->getRowSetMemoryOwner(), true);
     return proxy->getOrAddTransient(str);
   }

int32_t RowFunctionManager::getOrAddTransient	(	int32_t	db_id,
		int32_t	dict_id,
		std::string	str
	)

inline

Definition at line 314 of file heavydbTypes.h.

References RowFunctionManager_getOrAddTransient().

Referenced by array_first_half__t32(), array_second_half__t32(), strtok_to_array(), strtok_to_array__1(), tarray_append(), text_encoding_dict_concat(), text_encoding_dict_concat2(), text_encoding_dict_concat3(), text_encoding_dict_copy(), and text_encoding_dict_copy_from().

                                                                            {
     return RowFunctionManager_getOrAddTransient(
         reinterpret_cast<int8_t*>(this), db_id, dict_id, str);
   }

Here is the call graph for this function:

Here is the caller graph for this function:

std::string RowFunctionManager::getString	(	int32_t	db_id,
		int32_t	dict_id,
		int32_t	string_id
	)

inline

Definition at line 62 of file RowFunctionManager.h.

References executor_.

                                                                                 {
     const auto proxy = executor_->getStringDictionaryProxy(
         {db_id, dict_id}, executor_->getRowSetMemoryOwner(), true);
     return proxy->getString(string_id);
   }

std::string RowFunctionManager::getString	(	int32_t	db_id,
		int32_t	dict_id,
		int32_t	string_id
	)

inline

Definition at line 299 of file heavydbTypes.h.

References RowFunctionManager_getString().

Referenced by array_first_half__t32(), array_second_half__t32(), strtok_to_array__1(), tarray_append(), text_encoding_dict_concat(), text_encoding_dict_concat2(), text_encoding_dict_concat3(), text_encoding_dict_copy(), and text_encoding_dict_copy_from().

                                                                          {
     return RowFunctionManager_getString(
         reinterpret_cast<int8_t*>(this), db_id, dict_id, string_id);
   }

Here is the call graph for this function:

Here is the caller graph for this function:

int8_t* RowFunctionManager::getStringDictionaryProxy	(	int32_t	db_id,
		int32_t	dict_id
	)

inline

Definition at line 110 of file RowFunctionManager.h.

References executor_.

                                                                           {
     auto* proxy = executor_->getStringDictionaryProxy(
         {db_id, dict_id}, executor_->getRowSetMemoryOwner(), true);
     return reinterpret_cast<int8_t*>(proxy);
   }

int8_t* RowFunctionManager::makeBuffer	(	int64_t	element_count,
		int64_t	element_size
	)

inline

Definition at line 116 of file RowFunctionManager.h.

References checked_malloc(), and executor_.

                                                                          {
     int8_t* buffer =
         reinterpret_cast<int8_t*>(checked_malloc((element_count + 1) * element_size));
     executor_->getRowSetMemoryOwner()->addVarlenBuffer(buffer);
     return buffer;
   }

Here is the call graph for this function:

int8_t* RowFunctionManager::makeBuffer	(	int64_t	element_count,
		int64_t	element_size
	)

inline

Definition at line 319 of file heavydbTypes.h.

References RowFunctionManager_makeBuffer().

                                                                   {
     return RowFunctionManager_makeBuffer(
         reinterpret_cast<int8_t*>(this), element_count, element_size);
   }

Here is the call graph for this function:

Member Data Documentation

const Executor* RowFunctionManager::executor_

Definition at line 124 of file RowFunctionManager.h.

Referenced by getOrAddTransient(), getString(), getStringDictionaryProxy(), and makeBuffer().

const RelAlgExecutionUnit& RowFunctionManager::ra_exe_unit_

Definition at line 125 of file RowFunctionManager.h.

Referenced by getDictDbId(), and getDictId().

The documentation for this struct was generated from the following files:

/home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/heavydbTypes.h
/home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/RowFunctionManager.h

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation