(sink_factory)
| 177 | lambda: pa.BufferOutputStream() |
| 178 | ]) |
| 179 | def test_file_read_all(sink_factory): |
| 180 | fixture = FileFormatFixture(sink_factory) |
| 181 | |
| 182 | batches = fixture.write_batches() |
| 183 | file_contents = pa.BufferReader(fixture.get_source()) |
| 184 | |
| 185 | reader = pa.ipc.open_file(file_contents) |
| 186 | |
| 187 | result = reader.read_all() |
| 188 | expected = pa.Table.from_batches(batches) |
| 189 | assert result.equals(expected) |
| 190 | |
| 191 | |
| 192 | def test_open_file_from_buffer(file_fixture): |
nothing calls this directly
no test coverage detected