arrow

type ArraySlice struct {
	// contains filtered or unexported fields
}

type CastMeta struct {
	Schema *arrow.Schema
	Arrays []any
}

type Castable interface {
	CastMeta() CastMeta
}

type Caster struct {
	// contains filtered or unexported fields
}

type CsvOptions struct {
	// Allocator specifies the Arrow memory allocator used while building records.
	Allocator memory.Allocator
	// Comment specifies the comment character used while parsing CSV files.
	Comment rune
	// Comma specifies the fields separation character used while parsing CSV files.
	Comma rune
	// CRLF specifies the line terminator used while writing CSV files.
	// If useCRLF is true, \r\n is used as the line terminator, otherwise \n is used.
	CRLF bool
	// Chunk specifies the chunk size used while parsing CSV files.
	// If n is zero or 1, no chunking will take place and the reader will create
	// one record per row.
	// If n is greater than 1, chunks of n rows will be read.
	// If n is negative, the reader will load the whole CSV file into memory and
	// create one big record with all the rows.
	Chunk int
	// Header enables or disables CSV-header handling.
	Header bool
	// WithNullReader sets options for a CSV Reader pertaining to NULL value
	// handling. If stringsCanBeNull is true, then a string that matches one of the
	// nullValues set will be interpreted as NULL. Numeric columns will be checked
	// for nulls in all cases. If no nullValues arguments are passed in, the
	// defaults set in NewReader() will be kept.
	//
	// When no NULL values is given, the default set is taken from DefaultNullValues.
	StringsCanBeNull bool
	NullValues       []string
	// WithNullWriter sets the null string written for NULL values. The default is
	// set in NewWriter().
	WriterNullString string
}

type DataTyper interface {
	DataType() arrow.DataType
}

type ErrDataTypeMismatch struct {
	Expected, Got arrow.DataType
}

type ErrNotCastable struct {
	Type    reflect.Type
	TypeSet TypeSet
}

type Formatter interface {
	FormatArray(w io.Writer, data *array.Data) (int, error)
	FormatRecord(w io.Writer, data *array.Record) (int, error)
}

type ID uint64

type Main struct {
	Storage    Storage
	Allocator  memory.Allocator
	Methods    *Methods
	CsvOptions CsvOptions
	// contains filtered or unexported fields
}

type Methods struct {
	CreateCsvReader func(r io.Reader, schema *arrow.Schema, opts CsvOptions) *csv.Reader
	Cast            func(data array.Interface, arr any) error
	Mapping         *mapping.Methods
	Log             zerolog.Logger
}

type RecordStorage struct {
	// contains filtered or unexported fields
}

type Storage struct {
	Arrays     mapping.Mut[ID, array.Interface]
	Records    mapping.Mut[ID, array.Record]
	Formatters mapping.Mut[ID, Formatter]
}

type TypeSet map[reflect.Type]struct{}