()
| 718 | |
| 719 | @pytest.mark.pandas |
| 720 | def test_multithreaded_read(): |
| 721 | df = alltypes_sample(size=10000) |
| 722 | |
| 723 | table = pa.Table.from_pandas(df) |
| 724 | |
| 725 | buf = io.BytesIO() |
| 726 | _write_table(table, buf, compression='SNAPPY', version='2.6') |
| 727 | |
| 728 | buf.seek(0) |
| 729 | table1 = _read_table(buf, use_threads=True) |
| 730 | |
| 731 | buf.seek(0) |
| 732 | table2 = _read_table(buf, use_threads=False) |
| 733 | |
| 734 | assert table1.equals(table2) |
| 735 | |
| 736 | |
| 737 | @pytest.mark.pandas |
nothing calls this directly
no test coverage detected