OmniSciDB
bf83d84833
|
Classes | |
class | null_type |
struct | null_type< TYPE, std::enable_if_t< std::is_integral< TYPE >::value > > |
struct | null_type< TYPE, std::enable_if_t< std::is_floating_point< TYPE >::value > > |
Typedefs | |
template<typename TYPE > | |
using | null_type_t = typename null_type< TYPE >::type |
Functions | |
SQLTypes | get_dict_index_type (const SQLTypeInfo &ti) |
SQLTypes | get_physical_type (const SQLTypeInfo &ti) |
template<typename TYPE , typename VALUE_ARRAY_TYPE > | |
void | create_or_append_value (const ScalarTargetValue &val_cty, std::shared_ptr< ValueArray > &values, const size_t max_size) |
template<typename TYPE > | |
void | create_or_append_validity (const ScalarTargetValue &value, const SQLTypeInfo &col_type, std::shared_ptr< std::vector< bool >> &null_bitmap, const size_t max_size) |
template<typename C_TYPE , typename ARROW_TYPE = typename CTypeTraits<C_TYPE>::ArrowType> | |
void | convert_column (ResultSetPtr result, size_t col, std::unique_ptr< int8_t[]> &values, std::unique_ptr< uint8_t[]> &is_valid, size_t entry_count, std::shared_ptr< Array > &out) |
std::pair< key_t, void * > | get_shm (size_t shmsz) |
std::pair< key_t, std::shared_ptr< Buffer > > | get_shm_buffer (size_t size) |
std::shared_ptr< arrow::DataType > | get_arrow_type (const SQLTypeInfo &sql_type, const ExecutorDeviceType device_type) |
template<typename BUILDER_TYPE , typename VALUE_ARRAY_TYPE > | |
void | appendToColumnBuilder (ArrowResultSetConverter::ColumnBuilder &column_builder, const ValueArray &values, const std::shared_ptr< std::vector< bool >> &is_valid) |
template<> | |
void | appendToColumnBuilder< arrow::StringDictionary32Builder, int32_t > (ArrowResultSetConverter::ColumnBuilder &column_builder, const ValueArray &values, const std::shared_ptr< std::vector< bool >> &is_valid) |
using anonymous_namespace{ArrowResultSetConverter.cpp}::null_type_t = typedef typename null_type<TYPE>::type |
Definition at line 156 of file ArrowResultSetConverter.cpp.
void anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder | ( | ArrowResultSetConverter::ColumnBuilder & | column_builder, |
const ValueArray & | values, | ||
const std::shared_ptr< std::vector< bool >> & | is_valid | ||
) |
Definition at line 1031 of file ArrowResultSetConverter.cpp.
References ARROW_THROW_NOT_OK, ArrowResultSetConverter::ColumnBuilder::builder, CHECK, ArrowResultSetConverter::ColumnBuilder::field, DateConverters::get_epoch_days_from_seconds(), and kMilliSecsPerSec.
void anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder< arrow::StringDictionary32Builder, int32_t > | ( | ArrowResultSetConverter::ColumnBuilder & | column_builder, |
const ValueArray & | values, | ||
const std::shared_ptr< std::vector< bool >> & | is_valid | ||
) |
Definition at line 1060 of file ArrowResultSetConverter.cpp.
References ARROW_THROW_NOT_OK, and CHECK.
void anonymous_namespace{ArrowResultSetConverter.cpp}::convert_column | ( | ResultSetPtr | result, |
size_t | col, | ||
std::unique_ptr< int8_t[]> & | values, | ||
std::unique_ptr< uint8_t[]> & | is_valid, | ||
size_t | entry_count, | ||
std::shared_ptr< Array > & | out | ||
) |
void anonymous_namespace{ArrowResultSetConverter.cpp}::create_or_append_validity | ( | const ScalarTargetValue & | value, |
const SQLTypeInfo & | col_type, | ||
std::shared_ptr< std::vector< bool >> & | null_bitmap, | ||
const size_t | max_size | ||
) |
Definition at line 109 of file ArrowResultSetConverter.cpp.
References CHECK, SQLTypeInfo::get_notnull(), inline_fp_null_val(), inline_int_null_val(), SQLTypeInfo::is_boolean(), SQLTypeInfo::is_dict_encoded_string(), SQLTypeInfo::is_fp(), SQLTypeInfo::is_integer(), SQLTypeInfo::is_time(), and UNREACHABLE.
void anonymous_namespace{ArrowResultSetConverter.cpp}::create_or_append_value | ( | const ScalarTargetValue & | val_cty, |
std::shared_ptr< ValueArray > & | values, | ||
const size_t | max_size | ||
) |
std::shared_ptr<arrow::DataType> anonymous_namespace{ArrowResultSetConverter.cpp}::get_arrow_type | ( | const SQLTypeInfo & | sql_type, |
const ExecutorDeviceType | device_type | ||
) |
Definition at line 879 of file ArrowResultSetConverter.cpp.
References foreign_storage::get_physical_type(), SQLTypeInfo::get_precision(), SQLTypeInfo::get_scale(), SQLTypeInfo::get_type_name(), GPU, SQLTypeInfo::is_dict_encoded_string(), kARRAY, kBIGINT, kBOOLEAN, kCHAR, kDATE, kDECIMAL, kDOUBLE, kFLOAT, kINT, kINTERVAL_DAY_TIME, kINTERVAL_YEAR_MONTH, kNUMERIC, kSMALLINT, kTEXT, kTIME, kTIMESTAMP, kTINYINT, kVARCHAR, and to_string().
Referenced by ArrowResultSetConverter::makeField().
|
inline |
Definition at line 55 of file ArrowResultSetConverter.cpp.
References CHECK, SQLTypeInfo::get_size(), SQLTypeInfo::get_type(), SQLTypeInfo::is_dict_encoded_string(), kBIGINT, kINT, kSMALLINT, and kTINYINT.
Referenced by ArrowResultSetConverter::initializeColumnBuilder().
|
inline |
Definition at line 72 of file ArrowResultSetConverter.cpp.
References CHECK, SQLTypeInfo::get_size(), SQLTypeInfo::get_type(), IS_INTEGER, kBIGINT, kINT, kSMALLINT, and kTINYINT.
std::pair<key_t, void*> anonymous_namespace{ArrowResultSetConverter.cpp}::get_shm | ( | size_t | shmsz | ) |
Definition at line 243 of file ArrowResultSetConverter.cpp.
Referenced by arrow::get_and_copy_to_shm(), and get_shm_buffer().
std::pair<key_t, std::shared_ptr<Buffer> > anonymous_namespace{ArrowResultSetConverter.cpp}::get_shm_buffer | ( | size_t | size | ) |
Definition at line 281 of file ArrowResultSetConverter.cpp.
References get_shm().
Referenced by ArrowResultSetConverter::getArrowResult().