arrow

package
v0.108.0 Latest Latest
Warning

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

Go to latest
Published: Mar 15, 2021 License: MIT Imports: 10 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AppendBool added in v0.49.0

func AppendBool(b array.Builder, v bool) error

AppendBool will append a bool to a compatible builder.

func AppendFloat added in v0.49.0

func AppendFloat(b array.Builder, v float64) error

AppendFloat will append a float64 to a compatible builder.

func AppendInt added in v0.49.0

func AppendInt(b array.Builder, v int64) error

AppendInt will append an int64 to a compatible builder.

func AppendString added in v0.49.0

func AppendString(b array.Builder, v string) error

AppendString will append a string to a compatible builder.

func AppendTime added in v0.49.0

func AppendTime(b array.Builder, v values.Time) error

AppendTime will append a Time value to a compatible builder.

func AppendUint added in v0.49.0

func AppendUint(b array.Builder, v uint64) error

AppendUint will append a uint64 to a compatible builder.

func AppendValue added in v0.49.0

func AppendValue(b array.Builder, v values.Value) error

AppendValue will append a value to the builder.

Be aware when using this function that it will perform more slowly than type switching the builder to its appropriate type and appending multiple values in a row.

func BoolSlice added in v0.12.0

func BoolSlice(arr *array.Boolean, i, j int) *array.Boolean

func FloatSlice added in v0.12.0

func FloatSlice(arr *array.Float64, i, j int) *array.Float64

func IntSlice added in v0.12.0

func IntSlice(arr *array.Int64, i, j int) *array.Int64

func NewAllocator added in v0.38.0

func NewAllocator(a *memory.Allocator) arrowmemory.Allocator

func NewBool added in v0.11.0

func NewBool(vs []bool, alloc *memory.Allocator) *array.Boolean

func NewBoolBuilder

func NewBoolBuilder(a *memory.Allocator) *array.BooleanBuilder

func NewBuilder added in v0.49.0

func NewBuilder(typ flux.ColType, mem memory.Allocator) array.Builder

NewBuilder constructs a new builder for the given column type. The allocator passed in must be non-nil.

func NewFloat added in v0.11.0

func NewFloat(vs []float64, alloc *memory.Allocator) *array.Float64

func NewFloatBuilder

func NewFloatBuilder(a *memory.Allocator) *array.Float64Builder

func NewInt added in v0.11.0

func NewInt(vs []int64, alloc *memory.Allocator) *array.Int64

func NewIntBuilder

func NewIntBuilder(a *memory.Allocator) *array.Int64Builder

func NewString added in v0.11.0

func NewString(vs []string, alloc *memory.Allocator) *array.Binary

func NewStringBuilder

func NewStringBuilder(a *memory.Allocator) *array.BinaryBuilder

func NewUint added in v0.11.0

func NewUint(vs []uint64, alloc *memory.Allocator) *array.Uint64

func NewUintBuilder

func NewUintBuilder(a *memory.Allocator) *array.Uint64Builder

func Repeat added in v0.55.0

func Repeat(v values.Value, n int, mem memory.Allocator) array.Interface

Repeat will construct an arrow array that repeats the value n times.

func Slice added in v0.55.0

func Slice(arr array.Interface, i, j int64) array.Interface

Slice will construct a new slice of the array using the given start and stop index. The returned array must be released.

This is functionally equivalent to using array.NewSlice, but array.NewSlice will construct an array.String when the data type is a string rather than an array.Binary.

func StringSlice added in v0.12.0

func StringSlice(arr *array.Binary, i, j int) *array.Binary

func UintSlice added in v0.12.0

func UintSlice(arr *array.Uint64, i, j int) *array.Uint64

Types

type TableBuffer added in v0.49.0

type TableBuffer struct {
	GroupKey flux.GroupKey
	Columns  []flux.ColMeta
	Values   []array.Interface
}

TableBuffer represents the buffered component of an arrow table.

TableBuffer is a low-level structure for creating a table that implements the flux.ColReader interface. It does not have very many guiding blocks to ensure it is used correctly.

A valid TableBuffer will have a number of columns that is equal in length to the number of values arrays. All of the values arrays will have the same length.

func (*TableBuffer) Bools added in v0.49.0

func (t *TableBuffer) Bools(j int) *array.Boolean

func (*TableBuffer) Cols added in v0.49.0

func (t *TableBuffer) Cols() []flux.ColMeta

func (*TableBuffer) Floats added in v0.49.0

func (t *TableBuffer) Floats(j int) *array.Float64

func (*TableBuffer) Ints added in v0.49.0

func (t *TableBuffer) Ints(j int) *array.Int64

func (*TableBuffer) Key added in v0.49.0

func (t *TableBuffer) Key() flux.GroupKey

func (*TableBuffer) Len added in v0.49.0

func (t *TableBuffer) Len() int

func (*TableBuffer) Release added in v0.49.0

func (t *TableBuffer) Release()

func (*TableBuffer) Retain added in v0.49.0

func (t *TableBuffer) Retain()

func (*TableBuffer) Strings added in v0.49.0

func (t *TableBuffer) Strings(j int) *array.Binary

func (*TableBuffer) Times added in v0.49.0

func (t *TableBuffer) Times(j int) *array.Int64

func (*TableBuffer) UInts added in v0.49.0

func (t *TableBuffer) UInts(j int) *array.Uint64

func (*TableBuffer) Validate added in v0.49.0

func (t *TableBuffer) Validate() error

Validate will validate that this TableBuffer has the proper structure.

Jump to

Keyboard shortcuts

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