()
| 951 | |
| 952 | @pytest.mark.pandas |
| 953 | def test_ipc_zero_copy_numpy(): |
| 954 | df = pd.DataFrame({'foo': [1.5]}) |
| 955 | |
| 956 | batch = pa.RecordBatch.from_pandas(df) |
| 957 | sink = pa.BufferOutputStream() |
| 958 | write_file(batch, sink) |
| 959 | buffer = sink.getvalue() |
| 960 | reader = pa.BufferReader(buffer) |
| 961 | |
| 962 | batches = read_file(reader) |
| 963 | |
| 964 | data = batches[0].to_pandas() |
| 965 | rdf = pd.DataFrame(data) |
| 966 | assert_frame_equal(df, rdf) |
| 967 | |
| 968 | |
| 969 | @pytest.mark.pandas |
nothing calls this directly
no test coverage detected