(tempdir)
| 900 | |
| 901 | |
| 902 | def test_empty_row_groups(tempdir): |
| 903 | # ARROW-3020 |
| 904 | table = pa.Table.from_arrays([pa.array([], type='int32')], ['f0']) |
| 905 | |
| 906 | path = tempdir / 'empty_row_groups.parquet' |
| 907 | |
| 908 | num_groups = 3 |
| 909 | with pq.ParquetWriter(path, table.schema) as writer: |
| 910 | for i in range(num_groups): |
| 911 | writer.write_table(table) |
| 912 | |
| 913 | reader = pq.ParquetFile(path) |
| 914 | assert reader.metadata.num_row_groups == num_groups |
| 915 | |
| 916 | for i in range(num_groups): |
| 917 | assert reader.read_row_group(i).equals(table) |
| 918 | |
| 919 | |
| 920 | def test_reads_over_batch(tempdir): |
nothing calls this directly
no test coverage detected