parquet

package
v0.0.0-...-d1e1776 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 10, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL