Skip to main content

serialize_batches_stream_bounded

Function serialize_batches_stream_bounded 

Source
pub fn serialize_batches_stream_bounded<'a, I>(
    schema: &Schema,
    batches: I,
    max_bytes: usize,
) -> Result<Vec<u8>, ArrowError>
where I: IntoIterator<Item = &'a RecordBatch>,
Expand description

Serializes batches as one Arrow IPC stream without allowing the writer to allocate beyond max_bytes.

ยงErrors

Returns [arrow_schema::ArrowError] if encoding fails or crosses the byte bound.