csv

Jul 18, 2023

Changes in this version

+ const CSV

+ var ErrMultipleNodesMatched = errors.New("Multiple nodes match query")

+ func Import(attributeID string, terms []TermSpec, startRow, nRows int, idRows []int, ...) (*ls.Layer, error)

+ func ImportSchema(ctx *ls.Context, rows [][]string, context map[string]interface{}) ([]*ls.Layer, error)

+ func ParseIngest(context *ls.Context, ingester *ls.Ingester, parser Parser, ...) (*lpg.Node, error)

+ func ReadCSV(input io.Reader, csvSeparator string) ([][]string, error)

+ func ReadExcel(input io.Reader) (map[string][][]string, error)

+ func StreamCSVRows(input io.Reader, csvSeparator string, headerRow int) (<-chan Row, error)

+ func StreamExcelSheetRows(input io.Reader, sheet string, headerRow int) (<-chan Row, error)

+ type CSVImportSpec struct

+ AttributeID string

+ EntityID string

+ EntityIDRows []int

+ LayerID string

+ LayerType string

+ NRows int

+ Required string

+ RootID string

+ StartRow int

+ Terms []TermSpec

+ ValueType string

+ func (spec CSVImportSpec) Import(records [][]string) (*ls.Layer, error)

+ type ErrColIndexOutOfBounds struct

+ For string

+ Index int

+ func (e ErrColIndexOutOfBounds) Error() string

+ type ErrInvalidID struct

+ Row int

+ func (e ErrInvalidID) Error() string

+ type Parser struct

+ ColumnNames []string

+ IngestNullValues bool

+ OnlySchemaAttributes bool

+ SchemaNode *lpg.Node

+ func (ing Parser) ParseDoc(context *ls.Context, baseID string, row []string) (ls.ParsedDocNode, error)

+ type Row struct

+ Err error

+ Headers []string

+ Index int

+ Row []string

+ type TermSpec struct

+ Array bool

+ ArraySeparator string

+ Term string

+ TermTemplate string

+ type Writer struct

+ Columns []WriterColumn

+ RowRootQuery string

+ func (wr *Writer) BuildRow(root *lpg.Node) ([]string, error)

+ func (wr *Writer) WriteHeader(writer *csv.Writer) error

+ func (wr *Writer) WriteRow(writer *csv.Writer, root *lpg.Node) error

+ func (wr *Writer) WriteRows(writer *csv.Writer, g *lpg.Graph) error

+ type WriterColumn struct

+ Name string

+ Query string