csv

Documentation

Index

• type Reader
  • func NewReader(readCloser io.ReadCloser, args *ReaderArgs) (*Reader, error)
  • func (r *Reader) Close() error
  • func (r *Reader) Read() (sql.Record, error)
• type ReaderArgs
  • func (args *ReaderArgs) IsEmpty() bool
  • func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error
• type Record
  • func NewRecord() *Record
  • func (r *Record) Get(name string) (*sql.Value, error)
  • func (r *Record) MarshalCSV(fieldDelimiter rune) ([]byte, error)
  • func (r *Record) MarshalJSON() ([]byte, error)
  • func (r *Record) Raw() (sql.SelectObjectFormat, interface{})
  • func (r *Record) Replace(_ jstream.KVS) error
  • func (r *Record) Set(name string, value *sql.Value) error
• type WriterArgs
  • func (args *WriterArgs) IsEmpty() bool
  • func (args *WriterArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

Types

type Reader

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

Reader - CSV record reader for S3Select.

func NewReader

func NewReader(readCloser io.ReadCloser, args *ReaderArgs) (*Reader, error)

NewReader - creates new CSV reader using readCloser.

func (*Reader) Close

func (r *Reader) Close() error

Close - closes underlaying reader.

func (*Reader) Read

func (r *Reader) Read() (sql.Record, error)

Read - reads single record.

type ReaderArgs

type ReaderArgs struct {
	FileHeaderInfo             string `xml:"FileHeaderInfo"`
	RecordDelimiter            string `xml:"RecordDelimiter"`
	FieldDelimiter             string `xml:"FieldDelimiter"`
	QuoteCharacter             string `xml:"QuoteCharacter"`
	QuoteEscapeCharacter       string `xml:"QuoteEscapeCharacter"`
	CommentCharacter           string `xml:"Comments"`
	AllowQuotedRecordDelimiter bool   `xml:"AllowQuotedRecordDelimiter"`
	// contains filtered or unexported fields
}

ReaderArgs - represents elements inside <InputSerialization><CSV> in request XML.

func (*ReaderArgs) IsEmpty

func (args *ReaderArgs) IsEmpty() bool

IsEmpty - returns whether reader args is empty or not.

func (*ReaderArgs) UnmarshalXML

func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

UnmarshalXML - decodes XML data.

type Record

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

Record - is CSV record.

func NewRecord

func NewRecord() *Record

NewRecord - creates new CSV record.

func (*Record) Get

func (r *Record) Get(name string) (*sql.Value, error)

Get - gets the value for a column name. CSV fields do not have any defined type (other than the default string). So this function always returns fields using sql.FromBytes so that the type specified/implied by the query can be used, or can be automatically converted based on the query.

func (*Record) MarshalCSV

func (r *Record) MarshalCSV(fieldDelimiter rune) ([]byte, error)

MarshalCSV - encodes to CSV data.

func (*Record) MarshalJSON

func (r *Record) MarshalJSON() ([]byte, error)

MarshalJSON - encodes to JSON data.

func (*Record) Raw

func (r *Record) Raw() (sql.SelectObjectFormat, interface{})

Raw - returns the underlying data with format info.

func (*Record) Replace

func (r *Record) Replace(_ jstream.KVS) error

Replace - is not supported for CSV

func (*Record) Set

func (r *Record) Set(name string, value *sql.Value) error

Set - sets the value for a column name.

type WriterArgs

type WriterArgs struct {
	QuoteFields          string `xml:"QuoteFields"`
	RecordDelimiter      string `xml:"RecordDelimiter"`
	FieldDelimiter       string `xml:"FieldDelimiter"`
	QuoteCharacter       string `xml:"QuoteCharacter"`
	QuoteEscapeCharacter string `xml:"QuoteEscapeCharacter"`
	// contains filtered or unexported fields
}

WriterArgs - represents elements inside <OutputSerialization><CSV/> in request XML.

func (*WriterArgs) IsEmpty

func (args *WriterArgs) IsEmpty() bool

IsEmpty - returns whether writer args is empty or not.

func (*WriterArgs) UnmarshalXML

func (args *WriterArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

UnmarshalXML - decodes XML data.