ArrowUtil.h File Reference

#include <arrow/status.h>
#include <arrow/util/macros.h>
#include <stdexcept>
#include "DataMgr/BufferMgr/BufferMgr.h"
#include "Shared/likely.h"

Include dependency graph for ArrowUtil.h:

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

Go to the source code of this file.

Macros
#define	ARROW_THROW_NOT_OK(s)
#define	ARROW_THROW_IF(condition, status)
#define	ARROW_ASSIGN_OR_THROW_IMPL(result_name, lhs, rexpr)
#define	ARROW_ASSIGN_OR_THROW_NAME(x, y)   ARROW_CONCAT(x, y)
#define	ARROW_ASSIGN_OR_THROW(lhs, rexpr)

Functions
void	arrow_status_throw (const ::arrow::Status &s)

Macro Definition Documentation

#define ARROW_ASSIGN_OR_THROW	(		lhs,
			rexpr
	)

Value:

ARROW_ASSIGN_OR_THROW_IMPL(             \
      ARROW_ASSIGN_OR_THROW_NAME(_error_or_value, __COUNTER__), lhs, rexpr);

Definition at line 60 of file ArrowUtil.h.

Referenced by ArrowResultSetConverter::getArrowResult(), ArrowResultSetConverter::getSerializedArrowOutput(), anonymous_namespace{DBHandler.cpp}::loadArrowStream(), and ArrowResultSet::resultSetArrowLoopback().

#define ARROW_ASSIGN_OR_THROW_IMPL	(		result_name,
			lhs,
			rexpr
	)

Value:

auto result_name = (rexpr);                               \
  ARROW_THROW_NOT_OK((result_name).status());               \
  lhs = std::move(result_name).MoveValueUnsafe();

Definition at line 53 of file ArrowUtil.h.

#define ARROW_ASSIGN_OR_THROW_NAME	(		x,
			y
	)		ARROW_CONCAT(x, y)

Definition at line 58 of file ArrowUtil.h.

#define ARROW_THROW_IF	(		condition,
			status
	)

Value:

do {                                    \
    if (ARROW_PREDICT_FALSE(condition)) { \
      ARROW_THROW_NOT_OK(status);         \
    }                                     \
  } while (0)

Definition at line 46 of file ArrowUtil.h.

#define ARROW_THROW_NOT_OK

(

s

)

Value:

do {                        \
    ::arrow::Status _s = (s); \
    if (UNLIKELY(!_s.ok())) { \
      arrow_status_throw(_s); \
    }                         \
  } while (0)

Definition at line 36 of file ArrowUtil.h.

Referenced by anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder(), anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder< arrow::Decimal128Builder, int64_t >(), anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder< arrow::StringBuilder, std::string >(), anonymous_namespace{ArrowResultSetConverter.cpp}::appendToColumnBuilder< arrow::StringDictionary32Builder, int32_t >(), anonymous_namespace{ArrowResultSetConverter.cpp}::appendToListColumnBuilder(), anonymous_namespace{ArrowResultSetConverter.cpp}::appendToListColumnBuilder< arrow::StringDictionaryBuilder, int64_t >(), ArrowResultSetConverter::finishColumnBuilder(), ArrowResultSetConverter::getArrowResult(), ArrowResultSetConverter::getSerializedArrowOutput(), ArrowResultSetConverter::initializeColumnBuilder(), main(), ArrowCsvForeignStorage::registerTable(), and ArrowResultSet::resultSetArrowLoopback().

Function Documentation

void arrow_status_throw ( const ::arrow::Status &  s )

inline

Definition at line 26 of file ArrowUtil.h.

                                                     {
  std::string message = s.ToString();
  switch (s.code()) {
    case ::arrow::StatusCode::OutOfMemory:
      throw OutOfMemory(message);
    default:
      throw std::runtime_error(message);
  }
}