Repository: arrow
Updated Branches:
refs/heads/master 8e8b17f99 -> 732a2059d
http://git-wip-us.apache.org/repos/asf/arrow/blob/732a2059/python/src/pyarrow/adapters/pandas.h
--
diff --git a/python/src/pyarrow/adapters/pandas.h
b/python/src/pyarrow/adapters/pandas.h
index 141d121..532495d 100644
--- a/python/src/pyarrow/adapters/pandas.h
+++ b/python/src/pyarrow/adapters/pandas.h
@@ -32,27 +32,26 @@ namespace arrow {
class Array;
class Column;
class MemoryPool;
+class Status;
} // namespace arrow
namespace pyarrow {
-class Status;
-
PYARROW_EXPORT
-Status ConvertArrayToPandas(const std::shared_ptr& arr,
PyObject* py_ref,
-PyObject** out);
+arrow::Status ConvertArrayToPandas(const std::shared_ptr& arr,
+PyObject* py_ref, PyObject** out);
PYARROW_EXPORT
-Status ConvertColumnToPandas(const std::shared_ptr& col,
PyObject* py_ref,
-PyObject** out);
+arrow::Status ConvertColumnToPandas(const std::shared_ptr& col,
+PyObject* py_ref, PyObject** out);
PYARROW_EXPORT
-Status PandasMaskedToArrow(arrow::MemoryPool* pool, PyObject* ao, PyObject* mo,
+arrow::Status PandasMaskedToArrow(arrow::MemoryPool* pool, PyObject* ao,
PyObject* mo,
std::shared_ptr* out);
PYARROW_EXPORT
-Status PandasToArrow(arrow::MemoryPool* pool, PyObject* ao,
+arrow::Status PandasToArrow(arrow::MemoryPool* pool, PyObject* ao,
std::shared_ptr* out);
} // namespace pyarrow
http://git-wip-us.apache.org/repos/asf/arrow/blob/732a2059/python/src/pyarrow/api.h
--
diff --git a/python/src/pyarrow/api.h b/python/src/pyarrow/api.h
index 72be6af..6dbbc45 100644
--- a/python/src/pyarrow/api.h
+++ b/python/src/pyarrow/api.h
@@ -18,8 +18,6 @@
#ifndef PYARROW_API_H
#define PYARROW_API_H
-#include "pyarrow/status.h"
-
#include "pyarrow/helpers.h"
#include "pyarrow/adapters/builtin.h"
http://git-wip-us.apache.org/repos/asf/arrow/blob/732a2059/python/src/pyarrow/common.cc
--
diff --git a/python/src/pyarrow/common.cc b/python/src/pyarrow/common.cc
index 09f3efb..fa875f2 100644
--- a/python/src/pyarrow/common.cc
+++ b/python/src/pyarrow/common.cc
@@ -21,10 +21,10 @@
#include
#include
-#include
-#include
+#include "arrow/util/memory-pool.h"
+#include "arrow/util/status.h"
-#include "pyarrow/status.h"
+using arrow::Status;
namespace pyarrow {
@@ -33,18 +33,18 @@ class PyArrowMemoryPool : public arrow::MemoryPool {
PyArrowMemoryPool() : bytes_allocated_(0) {}
virtual ~PyArrowMemoryPool() {}
- arrow::Status Allocate(int64_t size, uint8_t** out) override {
+ Status Allocate(int64_t size, uint8_t** out) override {
std::lock_guard guard(pool_lock_);
*out = static_cast(std::malloc(size));
if (*out == nullptr) {
std::stringstream ss;
ss << "malloc of size " << size << " failed";
- return arrow::Status::OutOfMemory(ss.str());
+ return Status::OutOfMemory(ss.str());
}
bytes_allocated_ += size;
-return arrow::Status::OK();
+return Status::OK();
}
int64_t bytes_allocated() const override {
http://git-wip-us.apache.org/repos/asf/arrow/blob/732a2059/python/src/pyarrow/common.h
--
diff --git a/python/src/pyarrow/common.h b/python/src/pyarrow/common.h
index 50c2577..7f3131e 100644
--- a/python/src/pyarrow/common.h
+++ b/python/src/pyarrow/common.h
@@ -29,13 +29,6 @@ namespace pyarrow {
#define PYARROW_IS_PY2 PY_MAJOR_VERSION <= 2
-#define RETURN_ARROW_NOT_OK(s) do { \
-arrow::Status _s = (s); \
-if (!_s.ok()) { \
- return Status::ArrowError(s.ToString()); \
-} \
- } while (0);
-
class OwnedRef {
public:
OwnedRef() : obj_(nullptr) {}
http://git-wip-us.apache.org/repos/asf/arrow/blob/732a2059/python/src/pyarrow/io.cc
--
diff --git a/python/src/pyarrow/io.cc b/python/src/pyarrow/io.cc
index 7bf32ff..e6dbc12 100644
--- a/python/src/pyarrow/io.cc
+++ b/python/src/pyarrow/io.cc
@@ -20,12 +20,13 @@
#include
#include
-#include
-#include
-#include
+#include "arrow/io/memory.h"
+#include "arrow/util/memory-pool.h"
+#include "arrow/util/status.h"
#include "pyarrow/common.h"
-#include "pyarrow/status.h"
+
+using arrow::Status;
namespace pyarrow {
@@ -41,7 +42,7 @@ PythonFile::~PythonFile() {
Py_DECREF(file_);
}
-static arrow::Status CheckPyError() {
+static Status CheckPyError() {
if (PyErr_Occurred()) {
PyObject *exc_type, *exc_value, *traceback;
PyErr_Fetch(_type, _value, );
@@ -51,35 +52,35 @@ static arrow::Status CheckPyError() {
Py_XDECREF(exc_value);
Py_XDECREF(traceback);
PyErr_Clear();
-return