Expand description
CSV format decoder implementing FormatDecoder.
Converts raw CSV byte payloads into Arrow RecordBatches.
Constructed once at CREATE SOURCE time with a frozen Arrow schema
and CSV format configuration. The decoder is stateless after
construction so the Ring 1 hot path has zero configuration lookups.
Uses the csv crate’s ByteRecord API for zero-copy field access
where possible. Type coercion (string → int, string → timestamp, etc.)
is performed during the Arrow builder append phase.
Structs§
- CsvDecoder
- Decodes CSV byte payloads into Arrow
RecordBatches. - CsvDecoder
Config - CSV decoder configuration.
- CsvEncoder
- Encodes Arrow
RecordBatches into CSV byte records viaarrow_csv::writer. - CsvEncoder
Config - Configuration for
CsvEncoder.
Enums§
- Field
Count Mismatch Strategy - Strategy for rows with incorrect field count.