Struct JsonStreamingSink 

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

JSON streaming sink that writes items as a JSON array.

The output format is a valid JSON array:

[
  { "field": "value1" },
  { "field": "value2" }
]

Type Parameters

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

Implementations

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

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

Creates a new JSON streaming sink.

Arguments

• path - Path to the output JSON file

Errors

Returns an error if the file cannot be created.

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

Creates a JSON streaming sink with pretty printing enabled.

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