Return the first record batch read from the IPC Stream buffer, disabling validation
(buf: &[u8])
| 2485 | /// Return the first record batch read from the IPC Stream buffer, |
| 2486 | /// disabling validation |
| 2487 | fn read_stream_skip_validation(buf: &[u8]) -> Result<RecordBatch, ArrowError> { |
| 2488 | let mut reader = unsafe { |
| 2489 | StreamReader::try_new(std::io::Cursor::new(buf), None)?.with_skip_validation(true) |
| 2490 | }; |
| 2491 | reader.next().unwrap() |
| 2492 | } |
| 2493 | |
| 2494 | fn roundtrip_ipc_stream(rb: &RecordBatch) -> RecordBatch { |
| 2495 | let buf = write_stream(rb); |
no test coverage detected