Skip to main content

parse_arrow_ipc

Function parse_arrow_ipc 

Source
pub fn parse_arrow_ipc(bytes: Bytes) -> Result<Vec<RecordBatch>>
Expand description

Parses Arrow IPC stream bytes into a vector of RecordBatches (zero-copy).

The returned batches share their underlying allocation with the input Bytes, so fixed-width columns do not incur any memcpy.

ยงErrors

Returns Error::Other wrapping an Arrow IPC decode error if bytes is not a valid Arrow IPC stream (or concatenation thereof).