Skip to main content

encode_batches

Function encode_batches 

Source
pub fn encode_batches(batches: &[RecordBatch]) -> Result<Vec<u8>, IpcError>
Expand description

Encode multiple RecordBatches sharing a schema as one IPC stream.

Useful for procedure plugins that ship a series of yielded rows in one call. All batches must use the same schema (Arrow IPC stream invariant).

ยงErrors