parquet

package
v0.0.0-...-fb0f190 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2022 License: AGPL-3.0 Imports: 9 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 {
	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.

Jump to

Keyboard shortcuts

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