Skip to main content

datasynth_output/streaming/
mod.rs

1//! Streaming output sinks for real-time data generation.
2//!
3//! This module provides file-based streaming sinks that implement the
4//! `StreamingSink` trait for CSV, JSON, and Parquet output with backpressure support.
5
6mod csv_sink;
7mod json_sink;
8mod parquet_sink;
9
10pub use csv_sink::CsvStreamingSink;
11pub use json_sink::{JsonStreamingSink, NdjsonStreamingSink};
12pub use parquet_sink::ParquetStreamingSink;