Skip to content

Commit

Permalink
Rewrite test py.test style
Browse files Browse the repository at this point in the history
  • Loading branch information
xhochy committed Jun 4, 2016
1 parent 9520c39 commit 2006e70
Showing 1 changed file with 13 additions and 32 deletions.
45 changes: 13 additions & 32 deletions python/pyarrow/tests/test_parquet.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,36 +27,17 @@
import os.path


def test_single_int64_column(tmpdir):
filename = tmpdir.join('single_int64_column.parquet')
data = [A.from_pylist(range(5))]
table = A.Table.from_arrays(('a', 'b'), data, 'table_name')
A.parquet.write_table(table, filename.strpath)
table_read = pyarrow.parquet.read_table(filename.strpath)
for col_written, col_read in zip(table.itercolumns(), table_read.itercolumns()):
assert col_written.name == col_read.name
assert col_read.data.num_chunks == 1
data_written = col_written.data.chunk(0)
data_read = col_read.data.chunk(0)
assert data_written == data_read
def test_single_pylist_column(tmpdir):
for dtype in [int, float]:
filename = tmpdir.join('single_{}_column.parquet'.format(dtype.__name__))
data = [A.from_pylist(map(dtype, range(5)))]
table = A.Table.from_arrays(('a', 'b'), data, 'table_name')
A.parquet.write_table(table, filename.strpath)
table_read = pyarrow.parquet.read_table(filename.strpath)
for col_written, col_read in zip(table.itercolumns(), table_read.itercolumns()):
assert col_written.name == col_read.name
assert col_read.data.num_chunks == 1
data_written = col_written.data.chunk(0)
data_read = col_read.data.chunk(0)
assert data_written == data_read

class TestParquetIO(unittest.TestCase):

def setUp(self):
self.temp_directory = mkdtemp()

def tearDown(self):
rmtree(self.temp_directory)

def test_single_int64_column(self):
filename = os.path.join(self.temp_directory, 'single_int64_column.parquet')
data = [A.from_pylist(range(5))]
table = A.Table.from_arrays(('a', 'b'), data, 'table_name')
A.parquet.write_table(table, filename)
table_read = pyarrow.parquet.read_table(filename)
for col_written, col_read in zip(table.itercolumns(), table_read.itercolumns()):
assert col_written.name == col_read.name
assert col_read.data.num_chunks == 1
data_written = col_written.data.chunk(0)
data_read = col_read.data.chunk(0)
assert data_written == data_read

0 comments on commit 2006e70

Please sign in to comment.