parquet

Documentation

Index

• type Reader
  • func NewReader(getReaderFunc func(offset, length int64) (io.ReadCloser, error), ...) (*Reader, error)
  • func (r *Reader) Close() error
  • func (r *Reader) Read(dst sql.Record) (rec sql.Record, rerr error)
• type ReaderArgs
  • func (args *ReaderArgs) IsEmpty() bool
  • func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

Types

type Reader

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

Reader - Parquet record reader for S3Select.

func NewReader

func NewReader(getReaderFunc func(offset, length int64) (io.ReadCloser, error), args *ReaderArgs) (*Reader, error)

NewReader - creates new Parquet reader using readerFunc callback.

func (*Reader) Close

func (r *Reader) Close() error

Close - closes underlying readers.

func (*Reader) Read

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

Read - reads single record.

type ReaderArgs

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

ReaderArgs - represents elements inside <InputSerialization><Parquet/> 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.