Struct CsvDataSource

datasource/csv.go:32–44

Csv DataSource, implements qlbridge schema DataSource, SourceConn, Scanner to allow csv files to be full featured databases. - very, very naive scanner, forward only single pass - can open a file with .Open() - assumes comma delimited - not thread-safe - does not implement write operations

//   - not thread-safe
//   - does not implement write operations
type CsvDataSource struct {
	table    string
	tbl      *schema.Table
	exit     <-chan bool
	csvr     *csv.Reader
	gz       *gzip.Reader
	rc       io.ReadCloser
	rowct    uint64
	headers  []string
	colindex map[string]int
	indexCol int
	filter   expr.Node
}

// NewCsvSource reader assumes we are getting first row as headers
// - optionally may be gzipped