parquet

Documentation

Index

• type FileRef
  • func (ref *FileRef) GetNumRows() (int64, error)
  • func (ref *FileRef) GetSchema() (*schema.PathMapType, error)
  • func (ref *FileRef) Open() error
  • func (ref *FileRef) ReadLines(startLine int64, offset int64) ([]map[string]interface{}, error)
• type ParquetReader

Types

type FileRef

type FileRef struct {
	Path      string
	IsOpen    bool
	NumOfRows int64
	// contains filtered or unexported fields
}

func (*FileRef) GetNumRows

func (ref *FileRef) GetNumRows() (int64, error)

func (*FileRef) GetSchema

func (ref *FileRef) GetSchema() (*schema.PathMapType, error)

func (*FileRef) Open

func (ref *FileRef) Open() error

func (*FileRef) ReadLines

func (ref *FileRef) ReadLines(startLine int64, offset int64) ([]map[string]interface{}, error)

type ParquetReader

type ParquetReader interface {
	New() *ParquetReader
	Open() error
	CloseFile() error
	ReadLines(startLine int64, offset int64) ([]interface{}, error)
	GetSchema() (*schema.PathMapType, error)
	GetNumRows() (int64, error)
}