You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2019/11/01 22:25:23 UTC
[beam] branch aaltay-patch-1 updated: Fix Table.from_arrays API
change
This is an automated email from the ASF dual-hosted git repository.
altay pushed a commit to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/aaltay-patch-1 by this push:
new c600ef5 Fix Table.from_arrays API change
new 05deffa Merge pull request #9971 from TheNeuralBit/aaltay-patch-1
c600ef5 is described below
commit c600ef5898930faf35631e6ebb32179d70f6e46b
Author: Brian Hulette <bh...@google.com>
AuthorDate: Fri Nov 1 14:44:07 2019 -0700
Fix Table.from_arrays API change
---
sdks/python/apache_beam/io/parquetio_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/parquetio_test.py b/sdks/python/apache_beam/io/parquetio_test.py
index 824341e..d6241bf 100644
--- a/sdks/python/apache_beam/io/parquetio_test.py
+++ b/sdks/python/apache_beam/io/parquetio_test.py
@@ -448,7 +448,7 @@ class TestParquet(unittest.TestCase):
def test_selective_columns(self):
file_name = self._write_data()
orig = self._records_as_arrow()
- expected_result = [pa.Table.from_arrays([orig.column('name')])]
+ expected_result = [pa.Table.from_arrays([orig.column('name')], names=['name'])]
self._run_parquet_test(file_name, ['name'], None, False, expected_result)
def test_sink_transform_multiple_row_group(self):