Module streaming 

Streaming output sinks for real-time data generation.

This module provides file-based streaming sinks that implement the StreamingSink trait for CSV, JSON, and Parquet output with backpressure support.

Structs

CsvStreamingSink

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

JsonStreamingSink

JSON streaming sink that writes items as a JSON array.

NdjsonStreamingSink

Newline-Delimited JSON (NDJSON) streaming sink.

ParquetStreamingSink

Parquet streaming sink that buffers items and writes in row groups.