formatters

type CSVFormatter struct{}

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

type CSVStreamingFormatter struct{}

type ColumnSchema interface {
	GetName() string
	GetType() string
}

type Formatter interface {
	// Format converts database rows to the target format
	Format(rows []map[string]interface{}) ([]byte, error)

	// Extension returns the file extension for this format (e.g., ".jsonl", ".csv", ".parquet")
	Extension() string

	// MIMEType returns the MIME type for this format
	MIMEType() string
}

type JSONLFormatter struct{}

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

type JSONLStreamingFormatter struct{}

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

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

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

type StreamWriter interface {
	// WriteChunk writes a chunk of rows to the output
	WriteChunk(rows []map[string]interface{}) error

	// Close finalizes the output (writes footers, flushes buffers, etc.)
	Close() error
}

type StreamingFormatter interface {
	// NewWriter creates a new StreamWriter that writes to the given io.Writer
	// schema provides column information needed for formats like CSV (headers) and Parquet (schema)
	NewWriter(w io.Writer, schema TableSchema) (StreamWriter, error)

	// Extension returns the file extension for this format (e.g., ".jsonl", ".csv", ".parquet")
	Extension() string

	// MIMEType returns the MIME type for this format
	MIMEType() string
}

type TableSchema interface {
	GetColumns() []ColumnSchema
}