parquet

Documentation

Index

• type Reader
  • func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error)
  • func (pr *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 {
	io.Closer
	// contains filtered or unexported fields
}

Reader implements reading records from parquet input.

func NewParquetReader

func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error)

NewParquetReader creates a Reader2 from a io.ReadSeekCloser.

func (*Reader) Read

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

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.