orc

package

v1.6.1 Latest Latest Go to latest Published: Aug 1, 2023 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func First(payload []byte, columns ...string) (result []interface{}, err error)

First selects a first row only, then stops.

func Range(payload []byte, f func(int, []interface{}) bool, columns ...string) error

Range is a helper function that ranges over a set of columns in an orc buffer

func SchemaFor(schema typeof.Schema) (*orc.TypeDescription, error)

SchemaFor generates a schema

type Iterator interface {
	io.Closer
	Range(f func(int, []interface{}) bool, columns ...string) (int, bool)
	Schema() typeof.Schema
}

Iterator represents orc data frame.

func FromBuffer(b []byte) (Iterator, error)

FromBuffer creates an iterator from a buffer.

func FromFile(filename string) (Iterator, error)

FromFile creates an iterator from a file.