(tempdir)
| 883 | |
| 884 | |
| 885 | def test_empty_row_groups(tempdir): |
| 886 | # ARROW-3020 |
| 887 | table = pa.Table.from_arrays([pa.array([], type='int32')], ['f0']) |
| 888 | |
| 889 | path = tempdir / 'empty_row_groups.parquet' |
| 890 | |
| 891 | num_groups = 3 |
| 892 | with pq.ParquetWriter(path, table.schema) as writer: |
| 893 | for i in range(num_groups): |
| 894 | writer.write_table(table) |
| 895 | |
| 896 | reader = pq.ParquetFile(path) |
| 897 | assert reader.metadata.num_row_groups == num_groups |
| 898 | |
| 899 | for i in range(num_groups): |
| 900 | assert reader.read_row_group(i).equals(table) |
| 901 | |
| 902 | |
| 903 | def test_reads_over_batch(tempdir): |
nothing calls this directly
no test coverage detected