Struct CsvStreamingSink 

pub struct CsvStreamingSink<T> { /* private fields */ }

CSV streaming sink that writes serializable items to a CSV file.

This sink writes each data item as a CSV row, handling headers automatically on the first write.

Type Parameters

• T - The type of items to write. Must implement Serialize.

Example

use datasynth_output::streaming::CsvStreamingSink;
use datasynth_core::traits::{StreamEvent, StreamingSink};

let mut sink = CsvStreamingSink::<MyData>::new("output.csv".into())?;
sink.process(StreamEvent::Data(my_data))?;
sink.close()?;

Implementations

impl<T: Serialize + Send> CsvStreamingSink<T>

pub fn new(path: PathBuf) -> SynthResult<Self>

Creates a new CSV streaming sink.

Arguments

• path - Path to the output CSV file

Errors

Returns an error if the file cannot be created.

pub fn with_header(path: PathBuf, header: &str) -> SynthResult<Self>

Creates a CSV streaming sink with a pre-written header.

Arguments

• path - Path to the output CSV file
• header - The header line (without newline)

pub fn path(&self) -> &PathBuf

Returns the path to the output file.

pub fn bytes_written(&self) -> u64

Returns the total bytes written.

Trait Implementations

impl<T: Serialize + Send> StreamingSink<T> for CsvStreamingSink<T>

fn process(&mut self, event: StreamEvent<T>) -> SynthResult<()>

Processes a stream event.

fn flush(&mut self) -> SynthResult<()>

Flushes any buffered data.

fn close(self) -> SynthResult<()>

Closes the sink and releases resources.

fn items_processed(&self) -> u64

Returns the number of items processed.