OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
ArrowResultSetConverter.cpp File Reference
#include "../Shared/DateConverters.h"
#include "ArrowResultSet.h"
#include "Execute.h"
#include "arrow/ipc/dictionary.h"
#include "arrow/ipc/options.h"
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <algorithm>
#include <cerrno>
#include <cstdio>
#include <cstdlib>
#include <future>
#include <string>
#include "arrow/api.h"
#include "arrow/io/memory.h"
#include "arrow/ipc/api.h"
#include "Shared/ArrowUtil.h"
+ Include dependency graph for ArrowResultSetConverter.cpp:

Go to the source code of this file.

Classes

class  anonymous_namespace{ArrowResultSetConverter.cpp}::ResultSetBuffer
 
class  anonymous_namespace{ArrowResultSetConverter.cpp}::null_type< TYPE, enable >
 
struct  anonymous_namespace{ArrowResultSetConverter.cpp}::null_type< TYPE, std::enable_if_t< std::is_integral< TYPE >::value > >
 
struct  anonymous_namespace{ArrowResultSetConverter.cpp}::null_type< TYPE, std::enable_if_t< std::is_floating_point< TYPE >::value > >
 

Namespaces

 anonymous_namespace{ArrowResultSetConverter.cpp}
 
 arrow
 

Macros

#define ARROW_RECORDBATCH_MAKE   arrow::RecordBatch::Make
 
#define ARROW_CONVERTER_DEBUG   true
 
#define ARROW_LOG(category)
 

Typedefs

template<typename TYPE >
using anonymous_namespace{ArrowResultSetConverter.cpp}::null_type_t = typename null_type< TYPE >::type
 

Functions

SQLTypes anonymous_namespace{ArrowResultSetConverter.cpp}::get_dict_index_type (const SQLTypeInfo &ti)
 
SQLTypes anonymous_namespace{ArrowResultSetConverter.cpp}::get_physical_type (const SQLTypeInfo &ti)
 
template<typename TYPE , typename VALUE_ARRAY_TYPE >
void anonymous_namespace{ArrowResultSetConverter.cpp}::create_or_append_value (const ScalarTargetValue &val_cty, std::shared_ptr< ValueArray > &values, const size_t max_size)
 
template<typename TYPE , typename VALUE_ARRAY_TYPE >
void anonymous_namespace{ArrowResultSetConverter.cpp}::create_or_append_value (const ArrayTargetValue &val_ctys, std::shared_ptr< ValueArray > &values, const size_t max_size)
 
void anonymous_namespace{ArrowResultSetConverter.cpp}::create_or_append_validity (const ArrayTargetValue &value, const SQLTypeInfo &col_type, std::shared_ptr< std::vector< bool >> &null_bitmap, const size_t max_size)
 
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)
 
template<typename C_TYPE , typename ARROW_TYPE = typename arrow::CTypeTraits<C_TYPE>::ArrowType>
void anonymous_namespace{ArrowResultSetConverter.cpp}::convert_column (ResultSetPtr result, size_t col, size_t entry_count, std::shared_ptr< arrow::Array > &out)
 
std::pair< key_t, void * > anonymous_namespace{ArrowResultSetConverter.cpp}::get_shm (size_t shmsz)
 
std::pair< key_t,
std::shared_ptr< arrow::Buffer > > 
anonymous_namespace{ArrowResultSetConverter.cpp}::get_shm_buffer (size_t size)
 
void anonymous_namespace{ArrowResultSetConverter.cpp}::remap_string_values (const ArrowResultSetConverter::ColumnBuilder &column_builder, const std::vector< uint8_t > &bitmap, std::vector< int64_t > &vec1d)
 
key_t arrow::get_and_copy_to_shm (const std::shared_ptr< Buffer > &data)
 
std::shared_ptr< arrow::DataType > anonymous_namespace{ArrowResultSetConverter.cpp}::get_arrow_type (const SQLTypeInfo &sql_type, const ExecutorDeviceType device_type)
 
template<typename BUILDER_TYPE , typename VALUE_ARRAY_TYPE >
void anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder (ArrowResultSetConverter::ColumnBuilder &column_builder, const ValueArray &values, const std::shared_ptr< std::vector< bool >> &is_valid)
 
template<>
void anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder< arrow::Decimal128Builder, int64_t > (ArrowResultSetConverter::ColumnBuilder &column_builder, const ValueArray &values, const std::shared_ptr< std::vector< bool >> &is_valid)
 
template<>
void anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder< arrow::StringBuilder, std::string > (ArrowResultSetConverter::ColumnBuilder &column_builder, const ValueArray &values, const std::shared_ptr< std::vector< bool >> &is_valid)
 
template<>
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)
 
template<typename BUILDER_TYPE , typename VALUE_TYPE >
void anonymous_namespace{ArrowResultSetConverter.cpp}::appendToListColumnBuilder (ArrowResultSetConverter::ColumnBuilder &column_builder, const ValueArray &values, const std::shared_ptr< std::vector< bool >> &is_valid)
 
template<>
void anonymous_namespace{ArrowResultSetConverter.cpp}::appendToListColumnBuilder< arrow::StringDictionaryBuilder, int64_t > (ArrowResultSetConverter::ColumnBuilder &column_builder, const ValueArray &values, const std::shared_ptr< std::vector< bool >> &is_valid)
 

Macro Definition Documentation

#define ARROW_CONVERTER_DEBUG   true

Definition at line 53 of file ArrowResultSetConverter.cpp.

#define ARROW_LOG (   category)
Value:
VLOG(1) << "[Arrow]" \
<< "[" << category "] "
#define VLOG(n)
Definition: Logger.h:388

Definition at line 55 of file ArrowResultSetConverter.cpp.

Referenced by ArrowResultSetConverter::getArrowResult().

#define ARROW_RECORDBATCH_MAKE   arrow::RecordBatch::Make

Definition at line 51 of file ArrowResultSetConverter.cpp.

Referenced by ArrowResultSetConverter::getArrowBatch().