Crate pulse_io 

pulse-io: simple I/O sources and sinks.

• FileSource: reads JSONL or CSV and emits JSON records with event-time
• FileSink: writes JSON lines to stdout or a file

Re-exports

pub use parquet_sink::ParquetSink;

pub use parquet_sink::ParquetSinkConfig;

pub use parquet_sink::PartitionSpec;

Modules

parquet_sink

Structs

FileSink

Writes each record value as a single JSON line to stdout or a file.

FileSource

Reads a file (JSONL or CSV) and emits records.

Enums

FileFormat

Supported file formats for FileSource.