()
| 701 | |
| 702 | @pytest.mark.pandas |
| 703 | def test_multithreaded_read(): |
| 704 | df = alltypes_sample(size=10000) |
| 705 | |
| 706 | table = pa.Table.from_pandas(df) |
| 707 | |
| 708 | buf = io.BytesIO() |
| 709 | _write_table(table, buf, compression='SNAPPY', version='2.6') |
| 710 | |
| 711 | buf.seek(0) |
| 712 | table1 = _read_table(buf, use_threads=True) |
| 713 | |
| 714 | buf.seek(0) |
| 715 | table2 = _read_table(buf, use_threads=False) |
| 716 | |
| 717 | assert table1.equals(table2) |
| 718 | |
| 719 | |
| 720 | @pytest.mark.pandas |
nothing calls this directly
no test coverage detected