You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by we...@apache.org on 2018/08/07 20:51:11 UTC

[arrow] branch master updated: ARROW-3009: [Python] Fix pyarrow ORC reader

This is an automated email from the ASF dual-hosted git repository.

wesm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git


The following commit(s) were added to refs/heads/master by this push:
     new 91ffc00  ARROW-3009: [Python] Fix pyarrow ORC reader
91ffc00 is described below

commit 91ffc00b0a8f76c8f6dc4ad1f14079d9937b3e71
Author: Jim Crist <ji...@gmail.com>
AuthorDate: Tue Aug 7 16:51:06 2018 -0400

    ARROW-3009: [Python] Fix pyarrow ORC reader
    
    This errored on master due to the removal of `RecordBatch.__init__` from
    public api. Replaced with equivalent function. Have tested that this
    works fine locally - can't test in arrow until test infrastructure for
    ORC is setup.
    
    Author: Jim Crist <ji...@gmail.com>
    
    Closes #2394 from jcrist/fix-orc-error and squashes the following commits:
    
    b312ed8c <Jim Crist> Fix pyarrow ORC reader
---
 python/pyarrow/_orc.pyx | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/python/pyarrow/_orc.pyx b/python/pyarrow/_orc.pyx
index c95bea2..9493f23 100644
--- a/python/pyarrow/_orc.pyx
+++ b/python/pyarrow/_orc.pyx
@@ -26,6 +26,7 @@ from pyarrow.includes.libarrow cimport *
 from pyarrow.lib cimport (check_status,
                           MemoryPool, maybe_unbox_memory_pool,
                           Schema, pyarrow_wrap_schema,
+                          pyarrow_wrap_batch,
                           RecordBatch,
                           pyarrow_wrap_table,
                           get_reader)
@@ -93,9 +94,7 @@ cdef class ORCReader:
                 (check_status(deref(self.reader)
                               .ReadStripe(stripe, indices, &sp_record_batch)))
 
-        batch = RecordBatch()
-        batch.init(sp_record_batch)
-        return batch
+        return pyarrow_wrap_batch(sp_record_batch)
 
     def read(self, include_indices=None):
         cdef: