Expand description
Streaming CSV ingestion with optional fast local path.
- Streaming path: works with local files and gzip/zstd.
- Fast local path: feature
fast_local, uncompressed local UTF-8 only.
Data shape:
CsvIngestSummary { row_count, headers }- Streaming rows:
ByteRecord(access withget(idx) -> Option<&[u8]>)
Structs§
- Byte
Record - A single CSV record stored as raw bytes.
- CsvIngest
Summary - A count-and-header summary of a parsed CSV stream.
- CsvMeta
- CsvOptions
- CSV dialect options shared by streaming and fast-local parsing.
- CsvParser
- A streaming, byte-oriented CSV parser.
- Transcoding
Error - A malformed byte sequence encountered while strictly transcoding to UTF-8.
Enums§
- CsvHeader
Mode - How the first CSV record is interpreted.
- CsvIngest
Error - Error returned by every public parsing path in this crate.
- CsvTerminator
- How CSV records are terminated.
- CsvTrim
- ASCII whitespace trimming applied while parsing byte records.
- Decode
Policy - Controls how malformed byte sequences are handled while transcoding to UTF-8.
Functions§
- build_
csv_ reader - Wrap an
AsyncReadwith optional decompression and UTF-8 transcoding. - fast_
local_ process fast_local - Fast local parser for uncompressed UTF-8 CSV files using mmap and parallel chunking.
- reader_
from_ path - Build a reader from a local file path (lightweight meta from extension).
- summarize_
csv_ path - Summarize a local CSV path and return the transport metadata used.
- summarize_
csv_ stream - Summarize a CSV stream using the record-oriented parser contract.
Type Aliases§
- Boxed
CsvReader - Type-erased asynchronous reader returned by the transport helpers.
- CsvResult