Documentation ¶
Index ¶
- type PReader
- type RawJSON
- type Reader
- type ReaderArgs
- type Record
- func (r *Record) Clone(dst sql.Record) sql.Record
- func (r *Record) Get(name string) (*sql.Value, error)
- func (r *Record) Raw() (sql.SelectObjectFormat, interface{})
- func (r *Record) Replace(k interface{}) error
- func (r *Record) Reset()
- func (r *Record) Set(name string, value *sql.Value) (sql.Record, error)
- func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error
- func (r *Record) WriteJSON(writer io.Writer) error
- type WriterArgs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PReader ¶
type PReader struct {
// contains filtered or unexported fields
}
PReader - JSON record reader for S3Select. Operates concurrently on line-delimited JSON.
func NewPReader ¶
func NewPReader(readCloser io.ReadCloser, args *ReaderArgs) *PReader
NewPReader - creates new parallel JSON reader using readCloser. Should only be used for LINES types.
type RawJSON ¶
type RawJSON []byte
RawJSON is a byte-slice that contains valid JSON
func (RawJSON) MarshalJSON ¶
MarshalJSON instance for []byte that assumes that byte-slice is already serialized JSON
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader - JSON record reader for S3Select.
func NewReader ¶
func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader
NewReader - creates new JSON reader using readCloser.
type ReaderArgs ¶
type ReaderArgs struct { ContentType string `xml:"Type"` // contains filtered or unexported fields }
ReaderArgs - represents elements inside <InputSerialization><JSON/> 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 { // Used in Set(), Marshal*() KVS jstream.KVS SelectFormat sql.SelectObjectFormat }
Record - is JSON record.
func NewRecord ¶
func NewRecord(f sql.SelectObjectFormat) *Record
NewRecord - creates new empty JSON record.
func (*Record) Raw ¶
func (r *Record) Raw() (sql.SelectObjectFormat, interface{})
Raw - returns the underlying representation.
type WriterArgs ¶
type WriterArgs struct { RecordDelimiter string `xml:"RecordDelimiter"` // contains filtered or unexported fields }
WriterArgs - represents elements inside <OutputSerialization><JSON/> 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.