orc

package
v0.0.0-...-7638244 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL