Versions in this module Expand all Collapse all v0 v0.40.4 May 19, 2022 Changes in this version + var ReadBufSize = 256 * 1024 + func WriteCSVRow(wr *bufio.Writer, record []*string, delim string, useCRLF bool) error + type CSVFileInfo struct + Columns []string + Delim string + EscapeQuotes bool + HasHeaderLine bool + func NewCSVInfo() *CSVFileInfo + func (info *CSVFileInfo) SetColumns(columns []string) *CSVFileInfo + func (info *CSVFileInfo) SetDelim(delim string) *CSVFileInfo + func (info *CSVFileInfo) SetEscapeQuotes(escapeQuotes bool) *CSVFileInfo + func (info *CSVFileInfo) SetHasHeaderLine(hasHeaderLine bool) *CSVFileInfo + type CSVReader struct + func NewCSVReader(nbf *types.NomsBinFormat, r io.ReadCloser, info *CSVFileInfo) (*CSVReader, error) + func OpenCSVReader(nbf *types.NomsBinFormat, path string, fs filesys.ReadableFS, ...) (*CSVReader, error) + func (csvr *CSVReader) Close(ctx context.Context) error + func (csvr *CSVReader) GetSchema() schema.Schema + func (csvr *CSVReader) ReadRow(ctx context.Context) (row.Row, error) + func (csvr *CSVReader) ReadSqlRow(crx context.Context) (sql.Row, error) + func (csvr *CSVReader) VerifySchema(outSch schema.Schema) (bool, error) + type CSVWriter struct + func NewCSVWriter(wr io.WriteCloser, outSch schema.Schema, info *CSVFileInfo) (*CSVWriter, error) + func (csvw *CSVWriter) Close(ctx context.Context) error + func (csvw *CSVWriter) GetSchema() schema.Schema + func (csvw *CSVWriter) WriteRow(ctx context.Context, r row.Row) error + func (csvw *CSVWriter) WriteSqlRow(ctx context.Context, r sql.Row) error