Skip to main content

write_ipc_stream_batches

Function write_ipc_stream_batches 

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

Write all batches from iter as a single Arrow IPC stream to writer.

iter must yield at least one batch; the schema is inferred from the first batch. Returns ArrowError::InvalidArgumentError if the iterator is empty. If you need to write an empty stream (schema only, no rows), construct a StreamWriter directly.