()
| 631 | |
| 632 | @pytest.mark.pandas |
| 633 | def test_v2_set_chunksize(): |
| 634 | df = pd.DataFrame({'A': np.arange(1000)}) |
| 635 | table = pa.table(df) |
| 636 | |
| 637 | buf = io.BytesIO() |
| 638 | write_feather(table, buf, chunksize=250, version=2) |
| 639 | |
| 640 | result = buf.getvalue() |
| 641 | |
| 642 | ipc_file = pa.ipc.open_file(pa.BufferReader(result)) |
| 643 | assert ipc_file.num_record_batches == 4 |
| 644 | assert len(ipc_file.get_batch(0)) == 250 |
| 645 | |
| 646 | |
| 647 | @pytest.mark.pandas |
nothing calls this directly
no test coverage detected