OmniSciDB
c1a53651b2
|
#include <heavydbTypes.h>
Public Member Functions | |
void | set_output_array_values_total_number (int32_t index, int64_t output_array_values_total_number) |
void | set_output_row_size (int64_t num_rows) |
void | disable_output_allocations () |
void | enable_output_allocations () |
int32_t | error_message (const char *message) |
template<typename T > | |
void | set_metadata (const std::string &key, const T &value) |
template<typename T > | |
void | get_metadata (const std::string &key, T &value) |
int32_t | getNewDictDbId () |
int32_t | getNewDictId () |
StringDictionaryProxy * | getStringDictionaryProxy (int32_t db_id, int32_t dict_id) |
std::string | getString (int32_t db_id, int32_t dict_id, int32_t string_id) |
const char * | getCString (int32_t db_id, int32_t dict_id, int32_t string_id) |
int32_t | getOrAddTransient (int32_t db_id, int32_t dict_id, std::string str) |
TableFunctionManager (const TableFunctionExecutionUnit &exe_unit, Executor *executor, std::vector< const int8_t * > &col_buf_ptrs, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner, bool is_singleton) | |
size_t | get_ncols () const |
size_t | get_nrows () const |
void | check_thread_id () const |
void | set_output_column (int32_t index, int8_t *ptr) |
void | set_output_array_values_total_number (int32_t index, int64_t output_array_values_total_number) |
void | allocate_output_buffers (int64_t output_num_rows) |
const char * | get_error_message () const |
void | set_error_message (const char *msg) |
void | set_metadata (const char *key, const uint8_t *raw_bytes, const size_t num_bytes, const TableFunctionMetadataType value_type) const |
void | get_metadata (const char *key, const uint8_t *&raw_bytes, size_t &num_bytes, TableFunctionMetadataType &value_type) const |
int32_t | getNewDictDbId () |
int32_t | getNewDictId () |
int8_t * | getStringDictionaryProxy (int32_t db_id, int32_t dict_id) |
std::string | getString (int32_t db_id, int32_t dict_id, int32_t string_id) |
const char * | getCString (int32_t db_id, int32_t dict_id, int32_t string_id) |
const int32_t | getOrAddTransient (int32_t db_id, int32_t dict_id, const std::string &str) |
bool | isSingleton () const |
~TableFunctionManager () | |
Static Public Member Functions | |
static TableFunctionManager * | get_singleton () |
static TableFunctionManager *& | get_singleton () |
Public Attributes | |
bool output_allocations_disabled | false |
std::unique_ptr < QueryMemoryInitializer > | query_buffers |
Private Member Functions | |
void | lock () |
void | unlock () |
Static Private Member Functions | |
static void | set_singleton (TableFunctionManager *instance) |
Private Attributes | |
const TableFunctionExecutionUnit & | exe_unit_ |
Executor * | executor_ |
std::vector< const int8_t * > & | col_buf_ptrs_ |
std::shared_ptr < RowSetMemoryOwner > | row_set_mem_owner_ |
std::vector< int64_t * > | output_col_buf_ptrs |
size_t | output_num_rows_ |
std::vector< int64_t > | output_array_values_total_number_ |
std::vector< int8_t * > | output_column_ptrs |
bool | is_singleton_ |
std::thread::id | thread_id_ |
std::string | error_message_ |
Definition at line 1214 of file heavydbTypes.h.
|
inline |
Definition at line 59 of file TableFunctionManager.h.
References get_ncols(), isSingleton(), output_array_values_total_number_, output_col_buf_ptrs, output_column_ptrs, and set_singleton().
|
inline |
Definition at line 274 of file TableFunctionManager.h.
References isSingleton(), and set_singleton().
|
inline |
Definition at line 120 of file TableFunctionManager.h.
References QueryMemoryDescriptor::addColSlotInfo(), QueryMemoryDescriptor::addColSlotInfoFlatBuffer(), align_to_int64(), CHECK, CHECK_EQ, CHECK_NE, check_thread_id(), col_buf_ptrs_, CPU, exe_unit_, executor_, get_ncols(), getVarlenArrayBufferSize(), initializeVarlenArray(), output_array_values_total_number_, output_col_buf_ptrs, output_column_ptrs, output_num_rows_, query_buffers, query_mem_desc, row_set_mem_owner_, QueryMemoryDescriptor::setOutputColumnar(), Column< T >::size(), TableFunction, TableFunctionExecutionUnit::target_exprs, and toString().
|
inline |
Definition at line 91 of file TableFunctionManager.h.
References thread_id_.
Referenced by allocate_output_buffers(), get_error_message(), set_error_message(), and set_output_column().
|
inline |
Definition at line 1231 of file heavydbTypes.h.
Referenced by linear_reg_fit_predict__cpu_template().
|
inline |
Definition at line 1233 of file heavydbTypes.h.
Referenced by linear_reg_fit_predict__cpu_template().
|
inline |
Definition at line 1235 of file heavydbTypes.h.
References TableFunctionManager_error_message().
|
inline |
Definition at line 206 of file TableFunctionManager.h.
References check_thread_id(), and error_message_.
|
inline |
Definition at line 224 of file TableFunctionManager.h.
References CHECK, and row_set_mem_owner_.
|
inline |
Definition at line 1249 of file heavydbTypes.h.
References heavydb.dtypes::T, and TableFunctionManager_get_metadata().
Referenced by tf_metadata_getter__cpu_template(), and tf_metadata_getter_bad__cpu_template().
|
inline |
Definition at line 86 of file TableFunctionManager.h.
References exe_unit_, and TableFunctionExecutionUnit::target_exprs.
Referenced by allocate_output_buffers(), set_output_array_values_total_number(), set_output_column(), and TableFunctionManager().
|
inline |
|
inlinestatic |
Definition at line 280 of file TableFunctionManager.h.
|
inlinestatic |
Definition at line 1215 of file heavydbTypes.h.
References TableFunctionManager_get_singleton().
Referenced by ct_sleep1__cpu_(), ct_sleep2(), set_singleton(), and sum_along_row__cpu_template().
|
inline |
Definition at line 255 of file TableFunctionManager.h.
References executor_, and row_set_mem_owner_.
|
inline |
Definition at line 1278 of file heavydbTypes.h.
References TableFunctionManager_getCString().
|
inline |
Definition at line 232 of file TableFunctionManager.h.
References executor_, row_set_mem_owner_, and TRANSIENT_DICT_ID.
|
inline |
Definition at line 1263 of file heavydbTypes.h.
References TableFunctionManager_getNewDictDbId().
Referenced by array_asarray__cpu_template().
|
inline |
Definition at line 238 of file TableFunctionManager.h.
References executor_, row_set_mem_owner_, and TRANSIENT_DICT_ID.
|
inline |
Definition at line 1266 of file heavydbTypes.h.
References TableFunctionManager_getNewDictId().
Referenced by array_asarray__cpu_template().
|
inline |
Definition at line 262 of file TableFunctionManager.h.
References executor_, and row_set_mem_owner_.
|
inline |
Definition at line 1282 of file heavydbTypes.h.
References TableFunctionManager_getOrAddTransient().
Referenced by array_asarray__cpu_template().
|
inline |
Definition at line 249 of file TableFunctionManager.h.
References executor_, and row_set_mem_owner_.
|
inline |
Definition at line 1274 of file heavydbTypes.h.
References TableFunctionManager_getString().
Referenced by array_asarray__cpu_template().
|
inline |
Definition at line 244 of file TableFunctionManager.h.
References executor_, and row_set_mem_owner_.
|
inline |
Definition at line 1269 of file heavydbTypes.h.
References TableFunctionManager_getStringDictionaryProxy().
|
inline |
Definition at line 272 of file TableFunctionManager.h.
References is_singleton_.
Referenced by TableFunctionManager(), and ~TableFunctionManager().
|
inlineprivate |
Definition at line 286 of file TableFunctionManager.h.
References TableFunctionManager_singleton_mutex.
Referenced by set_singleton().
|
inline |
Definition at line 211 of file TableFunctionManager.h.
References check_thread_id(), and error_message_.
|
inline |
Definition at line 216 of file TableFunctionManager.h.
References CHECK, and row_set_mem_owner_.
|
inline |
Definition at line 1240 of file heavydbTypes.h.
References TableFunctionManager_set_metadata().
Referenced by GeoRaster< T, Z >::setMetadata(), tf_metadata_setter__cpu_template(), tf_metadata_setter_repeated__cpu_template(), and tf_metadata_setter_size_mismatch__cpu_template().
|
inline |
Definition at line 107 of file TableFunctionManager.h.
References CHECK_EQ, CHECK_LE, CHECK_LT, get_ncols(), output_array_values_total_number_, and output_num_rows_.
|
inline |
Definition at line 1219 of file heavydbTypes.h.
References TableFunctionManager_set_output_array_values_total_number().
Referenced by array_asarray__cpu_template(), array_concat__cpu_template(), array_copier__cpu_template(), and array_split__cpu_template().
|
inline |
Definition at line 99 of file TableFunctionManager.h.
References CHECK, check_thread_id(), get_ncols(), and output_column_ptrs.
|
inline |
Definition at line 1225 of file heavydbTypes.h.
References TableFunctionManager_set_output_row_size().
Referenced by array_asarray__cpu_template(), array_concat__cpu_template(), array_copier__cpu_template(), array_split__cpu_template(), ct_add_size_and_mul_alpha(), ct_copy_and_add_size(), ct_cursor_named_args__cpu_(), ct_pushdown_projection__cpu_template(), ct_pushdown_stats__cpu_template(), ct_scalar_named_args__cpu_(), ct_sleep2(), ct_sparse_add(), ct_string_concat__cpu_(), ct_substr__cpu_(), ct_synthesize_new_dict__cpu_(), ct_test_preflight_multicursor_qe227__cpu_(), ct_test_preflight_singlecursor_qe227__cpu_(), ct_throw_if_gt_100__cpu_template(), ct_timestamp_add_interval__template(), ct_timestamp_add_offset(), ct_timestamp_column_list_input(), ct_timestamp_extract(), ct_timestamp_truncate(), ct_union_pushdown_projection__cpu_template(), ct_union_pushdown_stats__cpu_template(), dbscan__cpu_template(), generate_random_strings__cpu_(), generate_series__cpu_template(), kmeans__cpu_template(), linear_reg_fit__cpu_template(), linear_reg_predict__cpu_template(), Mandelbrot::mandelbrot_cpu_template(), GeoRaster< T, Z >::outputDenseColumns(), supported_ml_frameworks__cpu_(), tf_metadata_getter__cpu_template(), tf_metadata_getter_bad__cpu_template(), tf_metadata_setter__cpu_template(), tf_metadata_setter_repeated__cpu_template(), and tf_metadata_setter_size_mismatch__cpu_template().
|
inlinestaticprivate |
Definition at line 289 of file TableFunctionManager.h.
References CHECK, get_singleton(), and lock().
Referenced by TableFunctionManager(), and ~TableFunctionManager().
|
inlineprivate |
Definition at line 287 of file TableFunctionManager.h.
References TableFunctionManager_singleton_mutex.
|
private |
Definition at line 305 of file TableFunctionManager.h.
Referenced by allocate_output_buffers().
|
private |
Definition at line 321 of file TableFunctionManager.h.
Referenced by get_error_message(), and set_error_message().
|
private |
Definition at line 302 of file TableFunctionManager.h.
Referenced by allocate_output_buffers(), and get_ncols().
|
private |
Definition at line 303 of file TableFunctionManager.h.
Referenced by allocate_output_buffers(), getCString(), getNewDictDbId(), getNewDictId(), getOrAddTransient(), getString(), and getStringDictionaryProxy().
bool output_allocations_disabled TableFunctionManager::false |
Definition at line 1297 of file heavydbTypes.h.
|
private |
Definition at line 317 of file TableFunctionManager.h.
Referenced by isSingleton().
|
private |
Definition at line 313 of file TableFunctionManager.h.
Referenced by allocate_output_buffers(), set_output_array_values_total_number(), and TableFunctionManager().
|
private |
Definition at line 309 of file TableFunctionManager.h.
Referenced by allocate_output_buffers(), and TableFunctionManager().
|
private |
Definition at line 315 of file TableFunctionManager.h.
Referenced by allocate_output_buffers(), set_output_column(), and TableFunctionManager().
|
private |
Definition at line 311 of file TableFunctionManager.h.
Referenced by allocate_output_buffers(), get_nrows(), and set_output_array_values_total_number().
std::unique_ptr<QueryMemoryInitializer> TableFunctionManager::query_buffers |
Definition at line 57 of file TableFunctionManager.h.
Referenced by allocate_output_buffers().
|
private |
Definition at line 307 of file TableFunctionManager.h.
Referenced by allocate_output_buffers(), get_metadata(), getCString(), getNewDictDbId(), getNewDictId(), getOrAddTransient(), getString(), getStringDictionaryProxy(), and set_metadata().
|
private |
Definition at line 319 of file TableFunctionManager.h.
Referenced by check_thread_id().