This commit is contained in:
Philipp Moritz committed 2019-05-25 18:20:20 -07:00
1 parent 364971c864
commit 6190645717
2 files changed
+8 -5

No files matched your search

+5 -5
View File
@@ -105,11 +105,11 @@ def read_json(input_file, read_options=None, parse_options=None,
_get_read_options(read_options, &c_read_options)
_get_parse_options(parse_options, &c_parse_options)
check_status(CJSONReader.Make(maybe_unbox_memory_pool(memory_pool),
stream, c_read_options, c_parse_options,
&reader))
# check_status(CJSONReader.Make(maybe_unbox_memory_pool(memory_pool),
# stream, c_read_options, c_parse_options,
# &reader))
with nogil:
check_status(reader.get().Read(&table))
# with nogil:
# check_status(reader.get().Read(&table))
return pyarrow_wrap_table(table)
+3
View File
@@ -1072,6 +1072,9 @@ cdef extern from "arrow/json/reader.h" namespace "arrow::json" nogil:
CStatus Read(shared_ptr[CTable]* out)
cdef CStatus ParseOne(CJSONParseOptions options, shared_ptr[CBuffer] json,
shared_ptr[CRecordBatch]* out)
cdef extern from "arrow/compute/api.h" namespace "arrow::compute" nogil: