parser

Jan 8, 2026

Changes in this version

+ type CSVConfig struct

+ Delimiter string

+ HasHeader bool

+ QuoteCharacter string

+ SkipRows int

+ type CSVParser struct

+ func NewCSVParser(config CSVConfig, stream *types.Stream) *CSVParser

+ func (p *CSVParser) InferSchema(_ context.Context, reader io.Reader) (*types.Stream, error)

+ func (p *CSVParser) StreamRecords(ctx context.Context, reader io.Reader, callback RecordCallback) error

+ type JSONConfig struct

+ LineDelimited bool

+ type JSONParser struct

+ func NewJSONParser(config JSONConfig, stream *types.Stream) *JSONParser

+ func (p *JSONParser) InferSchema(_ context.Context, reader io.Reader) (*types.Stream, error)

+ func (p *JSONParser) StreamRecords(ctx context.Context, reader io.Reader, callback RecordCallback) error

+ type ParquetConfig struct

+ StreamingEnabled bool

+ type ParquetParser struct

+ func NewParquetParser(config ParquetConfig, stream *types.Stream) *ParquetParser

+ func (p *ParquetParser) InferSchema(_ context.Context, reader io.Reader) (*types.Stream, error)

+ func (p *ParquetParser) StreamRecords(ctx context.Context, reader io.Reader, callback RecordCallback) error

+ type ParquetReaderWrapper struct

+ func NewParquetReaderWrapper(readerAt io.ReaderAt, size int64) *ParquetReaderWrapper

+ func (w *ParquetReaderWrapper) Read(p []byte) (n int, err error)

+ func (w *ParquetReaderWrapper) ReadAt(p []byte, off int64) (n int, err error)

+ func (w *ParquetReaderWrapper) Seek(offset int64, whence int) (int64, error)

+ type Parser interface

+ InferSchema func(ctx context.Context, reader io.Reader) (*types.Stream, error)

+ StreamRecords func(ctx context.Context, reader io.Reader, callback RecordCallback) error

+ type RecordCallback func(ctx context.Context, record map[string]any) error