Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader reads CSV data into columnar RecordBatches.
func NewReader ¶
func NewReader(data []byte, cfg ReaderConfig) (*Reader, error)
NewReader creates a CSV reader from raw bytes with the given config.
func NewStreamReader ¶
func NewStreamReader(r io.Reader, cfg ReaderConfig) (*Reader, error)
NewStreamReader creates a streaming CSV reader from an io.Reader. Reads the header and a sample of rows for schema inference, then streams remaining rows on demand via Next(). Memory usage is O(batch_size) instead of O(total_rows).
type ReaderConfig ¶
type ReaderConfig struct {
Delimiter rune // field delimiter (default: ',')
HasHeader bool // whether the first row is a header (default: true)
}
ReaderConfig controls CSV parsing behavior.
func DefaultConfig ¶
func DefaultConfig() ReaderConfig
DefaultConfig returns sensible defaults for CSV reading.
Source Files
Click to show internal directories.
Click to hide internal directories.