orc

Documentation

Index

• type OrcFileReader
  • func New(reader orc.SizedReaderAt) (*OrcFileReader, error)
  • func (r *OrcFileReader) Read() (row *util.Row, err error)
  • func (r *OrcFileReader) ReadHeader() (fieldNames []string, err error)
  • func (r *OrcFileReader) Select(fields []string) *OrcFileReader

Types

type OrcFileReader

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

func New

func New(reader orc.SizedReaderAt) (*OrcFileReader, error)

TODO predicate pushdown

func (*OrcFileReader) Read

func (r *OrcFileReader) Read() (row *util.Row, err error)

func (*OrcFileReader) ReadHeader

func (r *OrcFileReader) ReadHeader() (fieldNames []string, err error)

func (*OrcFileReader) Select

func (r *OrcFileReader) Select(fields []string) *OrcFileReader