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 bf138a8 ARROW-4576: [Python] Fix error during benchmarks
bf138a8 is described below
commit bf138a848e6c52fc9372b3fc7c5001dbd7f70bab
Author: Antoine Pitrou <[email protected]>
AuthorDate: Fri Feb 15 00:52:04 2019 -0600
ARROW-4576: [Python] Fix error during benchmarks
Author: Antoine Pitrou <[email protected]>
Closes #3650 from pitrou/ARROW-4576-py-benchmarks-fix and squashes the
following commits:
67e8069d1 <Antoine Pitrou> ARROW-4576: Fix error during benchmarks
---
python/benchmarks/streaming.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/python/benchmarks/streaming.py b/python/benchmarks/streaming.py
index 2012141..c0c63e6 100644
--- a/python/benchmarks/streaming.py
+++ b/python/benchmarks/streaming.py
@@ -62,7 +62,7 @@ class StreamReader(object):
stream_writer = pa.RecordBatchStreamWriter(sink, schema)
for batch in batches:
stream_writer.write_batch(batch)
- self.source = sink.get_result()
+ self.source = sink.getvalue()
def time_read_to_dataframe(self, *args):
reader = pa.RecordBatchStreamReader(self.source)