MCPcopy Create free account
hub / github.com/apache/arrow-rs / read_stream_skip_validation

Function read_stream_skip_validation

arrow-ipc/src/reader.rs:2487–2492  ·  view source on GitHub ↗

Return the first record batch read from the IPC Stream buffer, disabling validation

(buf: &[u8])

Source from the content-addressed store, hash-verified

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);

Callers 1

Calls 3

try_newFunction · 0.85
with_skip_validationMethod · 0.45
nextMethod · 0.45

Tested by

no test coverage detected