Crate kyu_copy 

kyu-copy: COPY FROM readers for CSV, Parquet, Arrow IPC, and Kafka.

Provides a unified DataReader trait and open_reader() factory that auto-detects the source format by URL scheme or file extension.

Re-exports

pub use kafka_reader::KafkaReader;

Modules

kafka_reader

Kafka topic reader for streaming ingestion.

Structs

ArrowIpcReader

Reads rows from an Arrow IPC file (.arrow / .ipc).

CsvReader

Reads rows from a CSV file, parsing each field according to the target schema.

ParquetReader

Reads rows from a Parquet file, converting Arrow arrays to TypedValue rows.

Traits

DataReader

Trait for reading rows from an external data source.

Functions

open_reader

Open a data reader for the given file path, auto-detecting format by extension.