Struct NdjsonStreamingSink 

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

Newline-Delimited JSON (NDJSON) streaming sink.

Each item is written as a separate JSON object on its own line:

{"field": "value1"}
{"field": "value2"}

This format is ideal for streaming and processing line by line.

Type Parameters

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

Implementations

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

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

Creates a new NDJSON streaming sink.

Arguments

• path - Path to the output NDJSON file

Errors

Returns an error if the file cannot be created.

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 NdjsonStreamingSink<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.