Function decode_arrow_ipc

nodedb/src/control/arrow_convert.rs:237–242

Decode Arrow IPC stream bytes back into a RecordBatch. Used by the Control Plane to receive Arrow data from the Data Plane across the SPSC bridge.

(bytes: &[u8])

/// Used by the Control Plane to receive Arrow data from the Data Plane
/// across the SPSC bridge.
pub fn decode_arrow_ipc(bytes: &[u8]) -> Option<RecordBatch> {
    use arrow::ipc::reader::StreamReader;
    let cursor = std::io::Cursor::new(bytes);
    let mut reader = StreamReader::try_new(cursor, None).ok()?;
    reader.next()?.ok()
}

#[cfg(test)]
mod tests {