#include "../Logger/Logger.h"
#include "funcannotations.h"
#include <cassert>
#include <cfloat>
#include <cstdint>
#include <cstdlib>
#include <limits>
#include <type_traits>

Include dependency graph for InlineNullValues.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	serialize_detail::IntType< overload >

struct	serialize_detail::IntType< 1 >

struct	serialize_detail::IntType< 2 >

struct	serialize_detail::IntType< 4 >

struct	serialize_detail::IntType< 8 >

Namespaces
	serialize_detail

Macros
#define	NULL_BOOLEAN INT8_MIN

#define	NULL_TINYINT INT8_MIN

#define	NULL_SMALLINT INT16_MIN

#define	NULL_INT INT32_MIN

#define	NULL_BIGINT INT64_MIN

#define	NULL_FLOAT FLT_MIN

#define	NULL_DOUBLE DBL_MIN

#define	NULL_ARRAY_BOOLEAN (INT8_MIN + 1)

#define	NULL_ARRAY_TINYINT (INT8_MIN + 1)

#define	NULL_ARRAY_SMALLINT (INT16_MIN + 1)

#define	NULL_ARRAY_INT (INT32_MIN + 1)

#define	NULL_ARRAY_BIGINT (INT64_MIN + 1)

#define	NULL_ARRAY_FLOAT (FLT_MIN * 2.0)

#define	NULL_ARRAY_DOUBLE (DBL_MIN * 2.0)

#define	NULL_ARRAY_COMPRESSED_32 0x80000000U

#define	CONSTEXPR constexpr

Functions
template<class T >
constexpr int64_t	inline_int_null_value ()

template<class T >
constexpr int64_t	inline_int_null_array_value ()

template<class T >
constexpr int64_t	max_valid_int_value ()

template<typename T >
constexpr T	inline_fp_null_value ()

template<>
constexpr float	inline_fp_null_value< float > ()

template<>
constexpr double	inline_fp_null_value< double > ()

template<typename T >
DEVICE T	inline_fp_null_array_value ()

template<>
DEVICE float	inline_fp_null_array_value< float > ()

template<>
DEVICE double	inline_fp_null_array_value< double > ()

template<typename SQL_TYPE_INFO >
int64_t	inline_int_null_val (const SQL_TYPE_INFO &ti)

template<typename SQL_TYPE_INFO >
int64_t	inline_fixed_encoding_null_val (const SQL_TYPE_INFO &ti)

template<typename SQL_TYPE_INFO >
double	inline_fp_null_val (const SQL_TYPE_INFO &ti)

template<typename SQL_TYPE_INFO >
int64_t	inline_int_null_array_val (const SQL_TYPE_INFO &ti)

template<typename SQL_TYPE_INFO >
int64_t	inline_fixed_encoding_null_array_val (const SQL_TYPE_INFO &ti)

template<typename T , bool array = false>
CONSTEXPR DEVICE serialize_detail::IntType < sizeof(T)>::type	serialized_null_value ()

template<typename T , bool array = false>
CONSTEXPR DEVICE bool	is_null (const T &value)

template<typename T >
CONSTEXPR DEVICE T	inline_null_value ()

template<typename T , bool array = false>
CONSTEXPR DEVICE void	set_null (T &value)

Macro Definition Documentation

#define CONSTEXPR constexpr

Definition at line 48 of file InlineNullValues.h.

Referenced by inline_null_value(), and serialized_null_value().

#define NULL_ARRAY_BIGINT (INT64_MIN + 1)

Definition at line 41 of file InlineNullValues.h.

Referenced by SQLTypeInfo::is_null_fixlen_array(), and FixedLengthArrayNoneEncoder::is_null_ignore_not_null().

#define NULL_ARRAY_BOOLEAN (INT8_MIN + 1)

Definition at line 37 of file InlineNullValues.h.

Referenced by FixedLengthArrayNoneEncoder::is_null_ignore_not_null().

#define NULL_ARRAY_COMPRESSED_32 0x80000000U

Definition at line 45 of file InlineNullValues.h.

Referenced by SQLTypeInfo::is_null_point_coord_array().

#define NULL_ARRAY_DOUBLE (DBL_MIN * 2.0)

Definition at line 43 of file InlineNullValues.h.

Referenced by Parser::InsertValuesStmt::analyze(), import_export::ImporterUtils::composeNullPointCoords(), Geospatial::compress_coords(), Geospatial::compress_null_point(), GeoPointValueConverter::convertToColumnarFormat(), GeoLinestringValueConverter::convertToColumnarFormat(), GeoPolygonValueConverter::convertToColumnarFormat(), GeoMultiPolygonValueConverter::convertToColumnarFormat(), spatial_type::PointConstructor::getNullCheckCodegen(), Geospatial::GeoTypesFactory::getNullGeoColumns(), inline_fp_null_array_value< double >(), SQLTypeInfo::is_null_fixlen_array(), FixedLengthArrayNoneEncoder::is_null_ignore_not_null(), Geospatial::is_null_point(), SQLTypeInfo::is_null_point_coord_array(), import_export::NullArrayDatum(), import_export::Importer::set_geo_physical_import_buffer(), import_export::Importer::set_geo_physical_import_buffer_columnar(), and foreign_storage::ParquetFixedLengthArrayEncoder::setNullFixedLengthArraySentinel().

#define NULL_ARRAY_FLOAT (FLT_MIN * 2.0)

Definition at line 42 of file InlineNullValues.h.

Referenced by inline_fp_null_array_value< float >(), SQLTypeInfo::is_null_fixlen_array(), FixedLengthArrayNoneEncoder::is_null_ignore_not_null(), import_export::NullArrayDatum(), and foreign_storage::ParquetFixedLengthArrayEncoder::setNullFixedLengthArraySentinel().

#define NULL_ARRAY_INT (INT32_MIN + 1)

Definition at line 40 of file InlineNullValues.h.

Referenced by SQLTypeInfo::is_null_fixlen_array(), and FixedLengthArrayNoneEncoder::is_null_ignore_not_null().

#define NULL_ARRAY_SMALLINT (INT16_MIN + 1)

Definition at line 39 of file InlineNullValues.h.

Referenced by SQLTypeInfo::is_null_fixlen_array(), and FixedLengthArrayNoneEncoder::is_null_ignore_not_null().

#define NULL_ARRAY_TINYINT (INT8_MIN + 1)

Definition at line 38 of file InlineNullValues.h.

Referenced by SQLTypeInfo::is_null_fixlen_array(), and FixedLengthArrayNoneEncoder::is_null_ignore_not_null().

#define NULL_BIGINT INT64_MIN

Definition at line 33 of file InlineNullValues.h.

Referenced by anonymous_namespace{DdlCommandExecutor.cpp}::add_table_details(), import_export::QueryExporterCSV::exportResults(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_array_column(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_scalar_column(), SQLTypeInfo::is_null(), Analyzer::anonymous_namespace{Analyzer.cpp}::is_null_value(), result_set::lazy_decode(), Analyzer::Constant::set_null_value(), import_export::anonymous_namespace{QueryExporterCSV.cpp}::target_value_to_string(), FixedLengthArrayNoneEncoder::update_elem_stats(), ArrayNoneEncoder::update_elem_stats(), DBHandler::value_to_thrift(), and DBHandler::value_to_thrift_column().

#define NULL_BOOLEAN INT8_MIN

Definition at line 29 of file InlineNullValues.h.

Referenced by import_export::QueryExporterCSV::exportResults(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_array_column(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_scalar_column(), SQLTypeInfo::is_null(), Analyzer::anonymous_namespace{Analyzer.cpp}::is_null_value(), Analyzer::Constant::set_null_value(), import_export::anonymous_namespace{QueryExporterCSV.cpp}::target_value_to_string(), FixedLengthArrayNoneEncoder::update_elem_stats(), ArrayNoneEncoder::update_elem_stats(), DBHandler::value_to_thrift(), and DBHandler::value_to_thrift_column().

#define NULL_DOUBLE DBL_MIN

Definition at line 35 of file InlineNullValues.h.

Referenced by import_export::TypedImportBuffer::add_value(), import_export::TypedImportBuffer::add_values(), import_export::TypedImportBuffer::addDefaultValues(), Parser::InsertValuesStmt::analyze(), ResultSet::calculateQuantile(), CodeGenerator::codegenConstantWidthBucketExpr(), CodeGenerator::codegenDiv(), CodeGenerator::codegenFpArith(), CodeGenerator::codegenIsNullNumber(), import_export::ImporterUtils::composeNullPointCoords(), Geospatial::compress_null_point(), GeoPointValueConverter::convertToColumnarFormat(), GeoLinestringValueConverter::convertToColumnarFormat(), GeoPolygonValueConverter::convertToColumnarFormat(), GeoMultiPolygonValueConverter::convertToColumnarFormat(), import_export::QueryExporterCSV::exportResults(), float_to_double_bin(), Geospatial::GeoPoint::getColumns(), Geospatial::GeoLineString::getColumns(), Geospatial::GeoPolygon::getColumns(), Geospatial::GeoMultiPolygon::getColumns(), Geospatial::GeoTypesFactory::getNullGeoColumns(), import_export::Importer::importGDALRaster(), inline_fp_null_value< double >(), CgenState::inlineFpNull(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_array_column(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_scalar_column(), SQLTypeInfo::is_null(), Analyzer::anonymous_namespace{Analyzer.cpp}::is_null_value(), ResultSet::makeTargetValue(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeApproxQuantileColumn(), import_export::NullDatum(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::operator()(), pair_to_double(), import_export::Importer::set_geo_physical_import_buffer(), import_export::Importer::set_geo_physical_import_buffer_columnar(), Analyzer::Constant::set_null_value(), import_export::TDatumToDatum(), FixedLengthArrayNoneEncoder::update_elem_stats(), ArrayNoneEncoder::update_elem_stats(), DBHandler::value_to_thrift(), and DBHandler::value_to_thrift_column().

#define NULL_FLOAT FLT_MIN

Definition at line 34 of file InlineNullValues.h.

Referenced by import_export::TypedImportBuffer::add_value(), import_export::TypedImportBuffer::add_values(), import_export::TypedImportBuffer::addDefaultValues(), CodeGenerator::codegenDiv(), CodeGenerator::codegenFpArith(), CodeGenerator::codegenIsNullNumber(), import_export::QueryExporterCSV::exportResults(), float_to_double_bin(), import_export::Importer::importGDALRaster(), inline_fp_null_value< float >(), CgenState::inlineFpNull(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_array_column(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_scalar_column(), SQLTypeInfo::is_null(), Analyzer::anonymous_namespace{Analyzer.cpp}::is_null_value(), null_val_bit_pattern(), import_export::NullDatum(), Analyzer::Constant::set_null_value(), import_export::TDatumToDatum(), FixedLengthArrayNoneEncoder::update_elem_stats(), ArrayNoneEncoder::update_elem_stats(), DBHandler::value_to_thrift(), and DBHandler::value_to_thrift_column().

#define NULL_INT INT32_MIN

Definition at line 32 of file InlineNullValues.h.

Referenced by anonymous_namespace{ResultSetIteration.cpp}::build_string_array_target_value(), GeoPolygonValueConverter::convertToColumnarFormat(), GeoMultiPolygonValueConverter::convertToColumnarFormat(), DictionaryConverterFactory< TARGET_TYPE >::create(), import_export::QueryExporterCSV::exportResults(), JoinColumnIterator::getElementSwitch(), import_export::Importer::importGDALRaster(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_array_column(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_scalar_column(), SQLTypeInfo::is_null(), Analyzer::anonymous_namespace{Analyzer.cpp}::is_null_value(), result_set::lazy_decode(), ResultSet::makeTargetValue(), Analyzer::Constant::set_null_value(), string_decompress(), FixedLengthArrayNoneEncoder::update_elem_stats(), ArrayNoneEncoder::update_elem_stats(), DBHandler::value_to_thrift(), and DBHandler::value_to_thrift_column().

#define NULL_SMALLINT INT16_MIN

Definition at line 31 of file InlineNullValues.h.

Referenced by import_export::QueryExporterCSV::exportResults(), JoinColumnIterator::getElementSwitch(), import_export::Importer::importGDALRaster(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_array_column(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_scalar_column(), SQLTypeInfo::is_null(), Analyzer::anonymous_namespace{Analyzer.cpp}::is_null_value(), result_set::lazy_decode(), Analyzer::Constant::set_null_value(), FixedLengthArrayNoneEncoder::update_elem_stats(), ArrayNoneEncoder::update_elem_stats(), DBHandler::value_to_thrift(), and DBHandler::value_to_thrift_column().

#define NULL_TINYINT INT8_MIN

Definition at line 30 of file InlineNullValues.h.

Referenced by import_export::QueryExporterCSV::exportResults(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_array_column(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_scalar_column(), SQLTypeInfo::is_null(), Analyzer::anonymous_namespace{Analyzer.cpp}::is_null_value(), Analyzer::Constant::set_null_value(), FixedLengthArrayNoneEncoder::update_elem_stats(), ArrayNoneEncoder::update_elem_stats(), DBHandler::value_to_thrift(), and DBHandler::value_to_thrift_column().

Function Documentation

template<typename SQL_TYPE_INFO >

int64_t inline_fixed_encoding_null_array_val ( const SQL_TYPE_INFO & ti )

inline

Definition at line 246 of file InlineNullValues.h.

References CHECK, CHECK_EQ, inline_int_null_array_val(), kENCODING_DATE_IN_DAYS, kENCODING_DICT, kENCODING_FIXED, and kENCODING_NONE.

Referenced by import_export::NullArrayDatum(), and foreign_storage::ParquetFixedLengthArrayEncoder::setNullFixedLengthArraySentinel().

                                                                              {
   if (ti.get_compression() == kENCODING_NONE) {
     return inline_int_null_array_val(ti);
   }
   if (ti.get_compression() == kENCODING_DATE_IN_DAYS) {
     switch (ti.get_comp_param()) {
       case 0:
       case 32:
         return inline_int_null_array_value<int32_t>();
       case 16:
         return inline_int_null_array_value<int16_t>();
       default:
 #ifndef __CUDACC__
         CHECK(false) << "Unknown encoding width for date in days: "
                      << ti.get_comp_param();
 #else
         CHECK(false);
 #endif
     }
   }
   if (ti.get_compression() == kENCODING_DICT) {
     CHECK(ti.is_string());
     switch (ti.get_size()) {
       case 1:
         return inline_int_null_array_value<uint8_t>();
       case 2:
         return inline_int_null_array_value<uint16_t>();
       case 4:
         return inline_int_null_array_value<int32_t>();
       default:
 #ifndef __CUDACC__
         CHECK(false) << "Unknown size for dictionary encoded type: " << ti.get_size();
 #else
         CHECK(false);
 #endif
     }
   }
 #ifndef __CUDACC__
   CHECK(false) << "Currently don't support fixed length arrays with fixed encoding";
 #else
   CHECK(false);
 #endif
   CHECK_EQ(kENCODING_FIXED, ti.get_compression());
   CHECK(ti.is_integer() || ti.is_time() || ti.is_decimal());
   CHECK_EQ(0, ti.get_comp_param() % 8);
   // The value of the NULL sentinel for fixed encoding is:
   //   -(1LL << (ti.get_comp_param() - 1))
   // NULL_ARRAY sentinel would have to be the value just above NULL:
   return -(1LL << (ti.get_comp_param() - 1)) + 1;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename SQL_TYPE_INFO >

int64_t inline_fixed_encoding_null_val ( const SQL_TYPE_INFO & ti )

inline

Definition at line 150 of file InlineNullValues.h.

References CHECK, CHECK_EQ, inline_int_null_val(), kENCODING_DATE_IN_DAYS, kENCODING_DICT, kENCODING_FIXED, and kENCODING_NONE.

Referenced by import_export::TypedImportBuffer::add_value(), import_export::TypedImportBuffer::add_values(), import_export::TypedImportBuffer::addDefaultValues(), RelAlgExecutor::executeSimpleInsert(), PerfectJoinHashTable::fetchColumnsForDevice(), BaselineJoinHashTable::fetchColumnsForDevice(), anonymous_namespace{ColumnarResults.cpp}::fixed_encoding_nullable_val(), PerfectJoinHashTable::getHashJoinArgs(), ResultSet::getUniqueStringsForDictEncodedTargetCol(), PerfectJoinHashTableBuilder::initOneToManyHashTableOnCpu(), PerfectJoinHashTableBuilder::initOneToOneHashTableOnCpu(), anonymous_namespace{RelAlgExecutor.cpp}::insert_one_dict_str(), anonymous_namespace{WindowContext.cpp}::integer_comparator(), result_set::lazy_decode(), import_export::NullDatum(), anonymous_namespace{ArrowImporter.h}::ArrowValue< void * >::operator DATA_TYPE(), anonymous_namespace{ArrowImporter.h}::ArrowValue< std::string >::operator DATA_TYPE(), QueryRewriter::rewriteColumnarUpdate(), synthesize_metadata_table_function(), and import_export::TDatumToDatum().

                                                                        {
   if (ti.get_compression() == kENCODING_NONE) {
     return inline_int_null_val(ti);
   }
   if (ti.get_compression() == kENCODING_DATE_IN_DAYS) {
     switch (ti.get_comp_param()) {
       case 0:
       case 32:
         return inline_int_null_value<int32_t>();
       case 16:
         return inline_int_null_value<int16_t>();
       default:
 #ifndef __CUDACC__
         CHECK(false) << "Unknown encoding width for date in days: "
                      << ti.get_comp_param();
 #else
         CHECK(false);
 #endif
     }
   }
   if (ti.get_compression() == kENCODING_DICT) {
     CHECK(ti.is_string());
     switch (ti.get_size()) {
       case 1:
         return inline_int_null_value<uint8_t>();
       case 2:
         return inline_int_null_value<uint16_t>();
       case 4:
         return inline_int_null_value<int32_t>();
       default:
 #ifndef __CUDACC__
         CHECK(false) << "Unknown size for dictionary encoded type: " << ti.get_size();
 #else
         CHECK(false);
 #endif
     }
   }
   CHECK_EQ(kENCODING_FIXED, ti.get_compression());
   CHECK(ti.is_integer() || ti.is_time() || ti.is_decimal());
   CHECK_EQ(0, ti.get_comp_param() % 8);
   return -(1LL << (ti.get_comp_param() - 1));
 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename T >

DEVICE T inline_fp_null_array_value ( )

Definition at line 94 of file InlineNullValues.h.

References logger::FATAL, LOG, and heavydb.dtypes::T.

                                       {
 #if !(defined(__CUDACC__) || defined(NO_BOOST))
   LOG(FATAL) << "Only float or double overloads should be called.";
 #else
   assert(false);
 #endif
   return T{};
 }

template<>

DEVICE double inline_fp_null_array_value< double > ( )

inline

Definition at line 109 of file InlineNullValues.h.

References NULL_ARRAY_DOUBLE.

Referenced by anonymous_namespace{TypedDataAccessors.h}::put_null_array().

                                                           {
   return NULL_ARRAY_DOUBLE;
 }

Here is the caller graph for this function:

template<>

DEVICE float inline_fp_null_array_value< float > ( )

inline

Definition at line 104 of file InlineNullValues.h.

References NULL_ARRAY_FLOAT.

Referenced by anonymous_namespace{TypedDataAccessors.h}::put_null_array().

                                                         {
   return NULL_ARRAY_FLOAT;
 }

Here is the caller graph for this function:

template<typename SQL_TYPE_INFO >

double inline_fp_null_val ( const SQL_TYPE_INFO & ti )

inline

Definition at line 194 of file InlineNullValues.h.

References CHECK, inline_fp_null_value< double >(), inline_fp_null_value< float >(), kDOUBLE, kFLOAT, and run_benchmark_import::type.

Referenced by CodeGenerator::codegenConstantWidthBucketExpr(), spatial_type::PointConstructor::codegenLoads(), GroupByAndAggregate::codegenOutputSlot(), Analyzer::WidthBucketExpr::compute_bucket(), anonymous_namespace{ArrowResultSetConverter.cpp}::create_or_append_validity(), anonymous_namespace{RelAlgTranslator.cpp}::datum_from_scalar_tv(), get_agg_initial_val(), anonymous_namespace{TypedDataAccessors.h}::NullSentinelSupplier::get_null_sentinel_for_type(), CgenState::getOrAddLiteral(), anonymous_namespace{Execute.cpp}::inline_null_val(), null_val_bit_pattern(), anonymous_namespace{ArrowImporter.h}::ArrowValue< void * >::operator DATA_TYPE(), synthesize_metadata(), and import_export::anonymous_namespace{QueryExporterCSV.cpp}::target_value_to_string().

                                                           {
   CHECK(ti.is_fp());
   const auto type = ti.get_type();
   switch (type) {
     case kFLOAT:
       return inline_fp_null_value<float>();
     case kDOUBLE:
       return inline_fp_null_value<double>();
     default:
       abort();
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename T >

constexpr T inline_fp_null_value ( )

inline

Definition at line 74 of file InlineNullValues.h.

References logger::FATAL, LOG, and heavydb.dtypes::T.

                                           {
 #if !(defined(__CUDACC__) || defined(NO_BOOST))
   LOG(FATAL) << "Only float or double overloads should be called.";
 #else
   LOG(FATAL);
 #endif
   return T{};
 }

template<>

constexpr double inline_fp_null_value< double > ( )

inline

Definition at line 89 of file InlineNullValues.h.

References NULL_DOUBLE.

Referenced by NumericConverterFactory< SOURCE_TYPE, TARGET_TYPE >::create(), anonymous_namespace{TypedDataAccessors.h}::get_scalar(), ArrowResultSet::getRowAt(), inline_fp_null_val(), anonymous_namespace{TypedDataAccessors.h}::put_null(), SqliteMemDatabase::runSelect(), synthesize_metadata_table_function(), and anonymous_namespace{ExternalExecutor.cpp}::vt_column().

                                                        {
   return NULL_DOUBLE;
 }

Here is the caller graph for this function:

template<>

constexpr float inline_fp_null_value< float > ( )

inline

Definition at line 84 of file InlineNullValues.h.

References NULL_FLOAT.

Referenced by NumericConverterFactory< SOURCE_TYPE, TARGET_TYPE >::create(), anonymous_namespace{TypedDataAccessors.h}::get_scalar(), ArrowResultSet::getRowAt(), inline_fp_null_val(), anonymous_namespace{TypedDataAccessors.h}::put_null(), SqliteMemDatabase::runSelect(), synthesize_metadata_table_function(), and anonymous_namespace{ExternalExecutor.cpp}::vt_column().

                                                      {
   return NULL_FLOAT;
 }

Here is the caller graph for this function:

template<typename SQL_TYPE_INFO >

int64_t inline_int_null_array_val ( const SQL_TYPE_INFO & ti )

inline

Definition at line 209 of file InlineNullValues.h.

References CHECK_EQ, kBIGINT, kBOOLEAN, kDATE, kDECIMAL, kENCODING_DICT, kENCODING_NONE, kINT, kINTERVAL_DAY_TIME, kINTERVAL_YEAR_MONTH, kNUMERIC, kSMALLINT, kTIME, kTIMESTAMP, kTINYINT, and run_benchmark_import::type.

Referenced by inline_fixed_encoding_null_array_val().

                                                                   {
   auto type = ti.get_type();
   if (ti.is_string()) {
     CHECK_EQ(kENCODING_DICT, ti.get_compression());
     CHECK_EQ(4, ti.get_logical_size());
     type = kINT;
   } else {
     CHECK_EQ(kENCODING_NONE, ti.get_compression());
   }
   // For all of the types below NULL sentinel is min of the range,
   // the value right above it is the NULL_ARRAY sentinel
   switch (type) {
     case kBOOLEAN:
       return inline_int_null_array_value<int8_t>();
     case kTINYINT:
       return inline_int_null_array_value<int8_t>();
     case kSMALLINT:
       return inline_int_null_array_value<int16_t>();
     case kINT:
       return inline_int_null_array_value<int32_t>();
     case kBIGINT:
       return inline_int_null_array_value<int64_t>();
     case kTIMESTAMP:
     case kTIME:
     case kDATE:
     case kINTERVAL_DAY_TIME:
     case kINTERVAL_YEAR_MONTH:
       return inline_int_null_array_value<int64_t>();
     case kDECIMAL:
     case kNUMERIC:
       return inline_int_null_array_value<int64_t>();
     default:
       abort();
   }
 }

Here is the caller graph for this function:

template<class T >

constexpr int64_t inline_int_null_array_value ( )

inline

Definition at line 60 of file InlineNullValues.h.

                                                        {
   return std::is_signed<T>::value ? std::numeric_limits<T>::min() + 1
                                   : std::numeric_limits<T>::max() - 1;
   // TODO: null_array values in signed types would step on max valid value
   // in fixlen unsigned arrays, the max valid value may need to be lowered.
 }

template<typename SQL_TYPE_INFO >

int64_t inline_int_null_val ( const SQL_TYPE_INFO & ti )

inline

Definition at line 115 of file InlineNullValues.h.

References CHECK_EQ, kBIGINT, kBOOLEAN, kDATE, kDECIMAL, kENCODING_DICT, kENCODING_NONE, kINT, kINTERVAL_DAY_TIME, kINTERVAL_YEAR_MONTH, kNUMERIC, kSMALLINT, kTIME, kTIMESTAMP, kTINYINT, and run_benchmark_import::type.

                                                             {
   auto type = ti.get_type();
   if (ti.is_string()) {
     CHECK_EQ(kENCODING_DICT, ti.get_compression());
     CHECK_EQ(4, ti.get_logical_size());
     type = kINT;
   } else {
     CHECK_EQ(kENCODING_NONE, ti.get_compression());
   }
   switch (type) {
     case kBOOLEAN:
       return inline_int_null_value<int8_t>();
     case kTINYINT:
       return inline_int_null_value<int8_t>();
     case kSMALLINT:
       return inline_int_null_value<int16_t>();
     case kINT:
       return inline_int_null_value<int32_t>();
     case kBIGINT:
       return inline_int_null_value<int64_t>();
     case kTIMESTAMP:
     case kTIME:
     case kDATE:
     case kINTERVAL_DAY_TIME:
     case kINTERVAL_YEAR_MONTH:
       return inline_int_null_value<int64_t>();
     case kDECIMAL:
     case kNUMERIC:
       return inline_int_null_value<int64_t>();
     default:
       abort();
   }
 }

Here is the caller graph for this function:

template<class T >

constexpr int64_t inline_int_null_value ( )

inline

Definition at line 54 of file InlineNullValues.h.

                                                  {
   return std::is_signed<T>::value ? std::numeric_limits<T>::min()
                                   : std::numeric_limits<T>::max();
 }

template<typename T >

CONSTEXPR DEVICE T inline_null_value ( )

inline

Definition at line 359 of file InlineNullValues.h.

References CHECK, and CONSTEXPR.

                                               {
   if
     CONSTEXPR(std::is_floating_point<T>::value) { return inline_fp_null_value<T>(); }
   else if
     CONSTEXPR(std::is_integral<T>::value) { return inline_int_null_value<T>(); }
 #if !(defined(__CUDACC__) || defined(NO_BOOST))
   else {
     CHECK(false) << "Serializing null values of floating point or integral types only is "
                     "supported.";
   }
 #endif
   return inline_int_null_value<int32_t>();  // dummy return
 }

template<typename T , bool array = false>

CONSTEXPR DEVICE bool is_null ( const T & value )

inline

Definition at line 353 of file InlineNullValues.h.

Referenced by import_export::TypedImportBuffer::addDefaultValues(), Parser::InsertValuesStmt::analyze(), ArrayNoneEncoder::appendData(), ChunkIter_get_nth(), ChunkIter_get_nth_point_coords(), spatial_type::Distance::codegenLoads(), spatial_type::PointAccessors::codegenLoads(), spatial_type::Transform::codegenLoads(), spatial_type::PointConstructor::codegenLoads(), convertBoolBitmapBufferWithNulls(), Fragmenter_Namespace::FixedLenArrayChunkConverter::convertToColumnarFormat(), ArrayValueConverter< ELEMENT_CONVERTER >::convertToColumnarFormat(), Parser::AddColumnStmt::execute(), RelAlgExecutor::executeSimpleInsert(), import_export::QueryExporterCSV::exportResults(), anonymous_namespace{ResultSetIteration.cpp}::GeoQueryOutputFetchHandler::fetch(), QueryRewriter::generateCaseExprForCountDistinctOnGroupByCol(), ArrayNoneEncoder::getArrayDatumAtIndex(), import_export::import_thread_delimited(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_array_column(), import_export::anonymous_namespace{QueryExporterGDAL.cpp}::insert_scalar_column(), anonymous_namespace{TypedDataAccessors.h}::integer_setter(), Column< T >::isNull(), Column< TextEncodingDict >::isNull(), foreign_storage::TextFileBufferParser::isNullDatum(), foreign_storage::CsvFileBufferParser::parseBuffer(), foreign_storage::RegexFileBufferParser::parseBuffer(), NumericValueConverter< int64_t, TARGET_TYPE >::processArrayBuffer(), DictionaryValueConverter< TARGET_TYPE >::processArrayBuffer(), anonymous_namespace{TypedDataAccessors.h}::put_scalar(), SqliteConnector::query_with_text_params(), ArrowForeignStorageBase::replaceNullValuesImpl(), Fragmenter_Namespace::set_chunk_stats(), import_export::StringToArray(), RelAlgTranslator::translateCurrentDate(), RelAlgTranslator::translateCurrentTime(), RelAlgTranslator::translateUoper(), and DBHandler::value_to_thrift_column().

                                                      {
   using TT = typename serialize_detail::IntType<sizeof(T)>::type;
   return serialized_null_value<T, array>() == *(TT*)(&value);
 }

Here is the caller graph for this function:

template<class T >

constexpr int64_t max_valid_int_value ( )

inline

Definition at line 68 of file InlineNullValues.h.

                                                {
   return std::is_signed<T>::value ? std::numeric_limits<T>::max()
                                   : std::numeric_limits<T>::max() - 1;
 }

template<typename T , bool array = false>

CONSTEXPR DEVICE serialize_detail::IntType<sizeof(T)>::type serialized_null_value ( )

inline

Definition at line 324 of file InlineNullValues.h.

References CHECK, CONSTEXPR, and heavydb.dtypes::T.

                         {
   using TT = typename serialize_detail::IntType<sizeof(T)>::type;
   T nv = 0;
   if
     CONSTEXPR(std::is_floating_point<T>::value) {
       if
         CONSTEXPR(array) { nv = inline_fp_null_array_value<T>(); }
       else {
         nv = inline_fp_null_value<T>();
       }
     }
   else if
     CONSTEXPR(std::is_integral<T>::value) {
       if
         CONSTEXPR(array) { nv = inline_int_null_array_value<T>(); }
       else {
         nv = inline_int_null_value<T>();
       }
     }
 #if !(defined(__CUDACC__) || defined(NO_BOOST))
   else {
     CHECK(false) << "Serializing null values of floating point or integral types only is "
                     "supported.";
   }
 #endif
   return *(TT*)(&nv);
 }

template<typename T , bool array = false>

CONSTEXPR DEVICE void set_null ( T & value )

inline

Definition at line 374 of file InlineNullValues.h.

Referenced by Column< T >::operator[](), Column< TextEncodingDict >::operator[](), foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::populate_import_buffers_for_catalog_users(), foreign_storage::anonymous_namespace{InternalMemoryStatsDataWrapper.cpp}::populate_import_buffers_for_memory_details(), foreign_storage::anonymous_namespace{InternalStorageStatsDataWrapper.cpp}::populate_import_buffers_for_storage_details(), set_null< Timestamp >(), Column< T >::setNull(), and Column< TextEncodingDict >::setNull().

                                                 {
   using TT = typename serialize_detail::IntType<sizeof(T)>::type;
   *(TT*)(&value) = serialized_null_value<T, array>();
 }

Here is the caller graph for this function:

Classes

Namespaces

Macros

Functions

Macro Definition Documentation

Function Documentation