orc

Documentation

Index

• func First(payload []byte, columns ...string) (result []interface{}, err error)
• func Range(payload []byte, f func(int, []interface{}) bool, columns ...string) error
• func SchemaFor(schema typeof.Schema) (*orc.TypeDescription, error)
• type Iterator
  • func FromBuffer(b []byte) (Iterator, error)
  • func FromFile(filename string) (Iterator, error)

Functions

func First

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

First selects a first row only, then stops.

func Range

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

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

SchemaFor generates a schema

Types

type Iterator

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

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

FromBuffer creates an iterator from a buffer.

func FromFile

func FromFile(filename string) (Iterator, error)

FromFile creates an iterator from a file.