(in_memory_pa_table)
| 126 | |
| 127 | |
| 128 | def test_in_memory_arrow_table_from_buffer(in_memory_pa_table): |
| 129 | with assert_arrow_memory_increases(): |
| 130 | buf_writer = pa.BufferOutputStream() |
| 131 | writer = pa.RecordBatchStreamWriter(buf_writer, schema=in_memory_pa_table.schema) |
| 132 | writer.write_table(in_memory_pa_table) |
| 133 | writer.close() |
| 134 | buf_writer.close() |
| 135 | pa_table = _in_memory_arrow_table_from_buffer(buf_writer.getvalue()) |
| 136 | assert in_memory_pa_table == pa_table |
| 137 | |
| 138 | |
| 139 | def test_memory_mapped_arrow_table_from_file(arrow_file, in_memory_pa_table): |
nothing calls this directly
no test coverage detected