mirror of
https://github.com/apache/arrow.git
synced 2026-10-29 17:15:39 +08:00
update
This commit is contained in:
1 parent
364971c864
commit
6190645717
2 files changed
+8
-5
No files matched your search
@@ -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)
|
||||
@@ -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:
|
||||
|
||||
|
||||
Reference in new issue
Block a user