anonymous_namespace{ArrowResultSetConverter.cpp} Namespace Reference

Functions
SQLTypes	get_dict_index_type (const SQLTypeInfo &ti)
SQLTypeInfo	get_dict_index_type_info (const SQLTypeInfo &ti)
SQLTypes	get_physical_type (const SQLTypeInfo &ti)
template<typename TYPE , typename C_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)

Function Documentation

create_or_append_validity()

template<typename TYPE >

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 120 of file ArrowResultSetConverter.cpp.

References CHECK, SQLTypeInfoCore< TYPE_FACET_PACK >::get_notnull(), inline_fp_null_val(), inline_int_null_val(), SQLTypeInfoCore< TYPE_FACET_PACK >::is_boolean(), SQLTypeInfoCore< TYPE_FACET_PACK >::is_dict_encoded_string(), SQLTypeInfoCore< TYPE_FACET_PACK >::is_fp(), SQLTypeInfoCore< TYPE_FACET_PACK >::is_integer(), SQLTypeInfoCore< TYPE_FACET_PACK >::is_time(), and UNREACHABLE.

                                                      {
  if (col_type.get_notnull()) {
    CHECK(!null_bitmap);
    return;
  }
  auto pvalue = boost::get<TYPE>(&value);
  CHECK(pvalue);
  bool is_valid = false;
  if (col_type.is_boolean()) {
    is_valid = inline_int_null_val(col_type) != static_cast<int8_t>(*pvalue);
  } else if (col_type.is_dict_encoded_string()) {
    is_valid = inline_int_null_val(col_type) != static_cast<int32_t>(*pvalue);
  } else if (col_type.is_integer() || col_type.is_time()) {
    is_valid = inline_int_null_val(col_type) != static_cast<int64_t>(*pvalue);
  } else if (col_type.is_fp()) {
    is_valid = inline_fp_null_val(col_type) != static_cast<double>(*pvalue);
  } else {
    UNREACHABLE();
  }

  if (!null_bitmap) {
    null_bitmap = std::make_shared<std::vector<bool>>();
    null_bitmap->reserve(max_size);
  }
  CHECK(null_bitmap);
  null_bitmap->push_back(is_valid);
}

Here is the call graph for this function:

create_or_append_value()

template<typename TYPE , typename C_TYPE >

void anonymous_namespace{ArrowResultSetConverter.cpp}::create_or_append_value	(	const ScalarTargetValue &	val_cty,
		std::shared_ptr< ValueArray > &	values,
		const size_t	max_size
	)

Definition at line 103 of file ArrowResultSetConverter.cpp.

References CHECK.

                                                   {
  auto pval_cty = boost::get<C_TYPE>(&val_cty);
  CHECK(pval_cty);
  auto val_ty = static_cast<TYPE>(*pval_cty);
  if (!values) {
    values = std::make_shared<ValueArray>(std::vector<TYPE>());
    boost::get<std::vector<TYPE>>(*values).reserve(max_size);
  }
  CHECK(values);
  auto values_ty = boost::get<std::vector<TYPE>>(values.get());
  CHECK(values_ty);
  values_ty->push_back(val_ty);
}

get_dict_index_type()

SQLTypes anonymous_namespace{ArrowResultSetConverter.cpp}::get_dict_index_type ( const SQLTypeInfo &  ti )

inline

Definition at line 49 of file ArrowResultSetConverter.cpp.

References CHECK, SQLTypeInfoCore< TYPE_FACET_PACK >::get_size(), SQLTypeInfoCore< TYPE_FACET_PACK >::get_type(), SQLTypeInfoCore< TYPE_FACET_PACK >::is_dict_encoded_string(), kBIGINT, kINT, kSMALLINT, and kTINYINT.

Referenced by ArrowResultSetConverter::initializeColumnBuilder().

                                                           {
  CHECK(ti.is_dict_encoded_string());
  switch (ti.get_size()) {
    case 1:
      return kTINYINT;
    case 2:
      return kSMALLINT;
    case 4:
      return kINT;
    case 8:
      return kBIGINT;
    default:
      CHECK(false);
  }
  return ti.get_type();
}

Here is the call graph for this function:

Here is the caller graph for this function:

get_dict_index_type_info()

SQLTypeInfo anonymous_namespace{ArrowResultSetConverter.cpp}::get_dict_index_type_info ( const SQLTypeInfo &  ti )

inline

Definition at line 66 of file ArrowResultSetConverter.cpp.

References CHECK, SQLTypeInfoCore< TYPE_FACET_PACK >::get_notnull(), SQLTypeInfoCore< TYPE_FACET_PACK >::get_size(), SQLTypeInfoCore< TYPE_FACET_PACK >::is_dict_encoded_string(), kBIGINT, kINT, kSMALLINT, and kTINYINT.

Referenced by ArrowResultSetConverter::getArrowType().

                                                                   {
  CHECK(ti.is_dict_encoded_string());
  switch (ti.get_size()) {
    case 1:
      return SQLTypeInfo(kTINYINT, ti.get_notnull());
    case 2:
      return SQLTypeInfo(kSMALLINT, ti.get_notnull());
    case 4:
      return SQLTypeInfo(kINT, ti.get_notnull());
    case 8:
      return SQLTypeInfo(kBIGINT, ti.get_notnull());
    default:
      CHECK(false);
  }
  return ti;
}

Here is the call graph for this function:

Here is the caller graph for this function:

get_physical_type()

SQLTypes anonymous_namespace{ArrowResultSetConverter.cpp}::get_physical_type ( const SQLTypeInfo &  ti )

inline

Definition at line 83 of file ArrowResultSetConverter.cpp.

References CHECK, SQLTypeInfoCore< TYPE_FACET_PACK >::get_size(), SQLTypeInfoCore< TYPE_FACET_PACK >::get_type(), IS_INTEGER, kBIGINT, kINT, kSMALLINT, and kTINYINT.

Referenced by ArrowResultSetConverter::getArrowType(), and ArrowResultSetConverter::initializeColumnBuilder().

                                                         {
  auto logical_type = ti.get_type();
  if (IS_INTEGER(logical_type)) {
    switch (ti.get_size()) {
      case 1:
        return kTINYINT;
      case 2:
        return kSMALLINT;
      case 4:
        return kINT;
      case 8:
        return kBIGINT;
      default:
        CHECK(false);
    }
  }
  return logical_type;
}

Here is the call graph for this function:

Here is the caller graph for this function: