Skip to main content

write_ipc_section_batches

lance_arrow::ipc

Function write_ipc_section_batches 

Source 
pub fn write_ipc_section_batches<I>(
    writer: &mut dyn Write,
    pos: &mut usize,
    iter: I,
) -> Result<(), ArrowError>
where
    I: IntoIterator<Item = RecordBatch>,
Expand description

Write batches as a single 64-byte-aligned multi-batch Arrow IPC section.

Like write_ipc_section but emits every batch from iter into one IPC stream (schema + N batches + EOS). iter must yield at least one batch. Paired with read_ipc_section_batches_at.