reader

Documentation

Index

• type ReadOpts
  • func NewReadOpts(count int64, skip int64) *ReadOpts
• type Reader
  • func NewReader(file source.ParquetFile, concurrency int64) *Reader
  • func (pr *Reader) CompressedSize() int64
  • func (pr *Reader) Read(opts *ReadOpts)
  • func (pr *Reader) ShowSchema(opts *SchemaOpts)
  • func (pr *Reader) UncompressedSize() int64
• type SchemaOpts
  • func NewSchemaOpts(format string, showTags bool) *SchemaOpts

Types

type ReadOpts

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

func NewReadOpts

func NewReadOpts(count int64, skip int64) *ReadOpts

type Reader

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

func NewReader

func NewReader(file source.ParquetFile, concurrency int64) *Reader

func (*Reader) CompressedSize

func (pr *Reader) CompressedSize() int64

func (*Reader) Read

func (pr *Reader) Read(opts *ReadOpts)

func (*Reader) ShowSchema

func (pr *Reader) ShowSchema(opts *SchemaOpts)

func (*Reader) UncompressedSize

func (pr *Reader) UncompressedSize() int64

type SchemaOpts

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

func NewSchemaOpts

func NewSchemaOpts(format string, showTags bool) *SchemaOpts