Thalweg · API reference ← Main docs

encode_ipc

Function encode_ipc 

Source
pub fn encode_ipc(batch: &RecordBatch) -> Result<Bytes, ZerobusSinkError>
Expand description

Serialise batch to a self-describing Arrow IPC stream (schema + one batch).

§Errors

ZerobusSinkError::Encode if the IPC writer fails.