Struct StreamingCSVWriter 

pub struct StreamingCSVWriter<W: Write> { /* private fields */ }

Streaming CSV writer for memory-efficient export of large datasets

Unlike the batch CSVWriter, this writer processes data incrementally, allowing export of arbitrarily large result sets within memory constraints.

Example

let file = File::create("output.csv")?;
let mut writer = StreamingCSVWriter::new(file);

writer.write_header(&metadata)?;

for chunk in result_iterator.chunks(10_000) {
    writer.write_chunk(&chunk)?;
}

writer.finalize()?;

Implementations

impl<W: Write> StreamingCSVWriter<W>

pub fn new(output: W) -> Self

Create a new streaming CSV writer

pub fn with_options(output: W, delimiter: u8, quote_style: QuoteStyle) -> Self

Create with custom CSV options

Trait Implementations

impl<W: Write + Send> StreamingWriter for StreamingCSVWriter<W>

fn write_header(&mut self, metadata: &QueryMetadata) -> Result<(), OutputError>

Initialize writer with column metadata (write header if applicable)

fn write_chunk(&mut self, rows: &[QueryRow]) -> Result<usize, OutputError>

Write a chunk of rows (called multiple times during streaming)

fn finalize(&mut self) -> Result<(), OutputError>

Finalize output (flush buffers, write footer, close resources)

fn rows_written(&self) -> u64

Get count of rows written so far

fn bytes_written(&self) -> Option<u64>

Get bytes written so far (if trackable)