(stream_fixture)
| 713 | |
| 714 | @pytest.mark.pandas |
| 715 | def test_stream_read_pandas(stream_fixture): |
| 716 | frames = [batch.to_pandas() for batch in stream_fixture.write_batches()] |
| 717 | file_contents = stream_fixture.get_source() |
| 718 | reader = pa.ipc.open_stream(file_contents) |
| 719 | result = reader.read_pandas() |
| 720 | |
| 721 | expected = pd.concat(frames).reset_index(drop=True) |
| 722 | assert_frame_equal(result, expected) |
| 723 | |
| 724 | |
| 725 | @pytest.fixture |
nothing calls this directly
no test coverage detected