arrow

Documentation

Index

• func AppendBool(b array.Builder, v bool) error
• func AppendFloat(b array.Builder, v float64) error
• func AppendInt(b array.Builder, v int64) error
• func AppendString(b array.Builder, v string) error
• func AppendTime(b array.Builder, v values.Time) error
• func AppendUint(b array.Builder, v uint64) error
• func AppendValue(b array.Builder, v values.Value) error
• func BoolSlice(arr *array.Boolean, i, j int) *array.Boolean
• func FloatSlice(arr *array.Float64, i, j int) *array.Float64
• func IntSlice(arr *array.Int64, i, j int) *array.Int64
• func NewAllocator(a *memory.Allocator) arrowmemory.Allocator
• func NewBool(vs []bool, alloc *memory.Allocator) *array.Boolean
• func NewBoolBuilder(a *memory.Allocator) *array.BooleanBuilder
• func NewBuilder(typ flux.ColType, mem memory.Allocator) array.Builder
• func NewFloat(vs []float64, alloc *memory.Allocator) *array.Float64
• func NewFloatBuilder(a *memory.Allocator) *array.Float64Builder
• func NewInt(vs []int64, alloc *memory.Allocator) *array.Int64
• func NewIntBuilder(a *memory.Allocator) *array.Int64Builder
• func NewString(vs []string, alloc *memory.Allocator) *array.Binary
• func NewStringBuilder(a *memory.Allocator) *array.BinaryBuilder
• func NewUint(vs []uint64, alloc *memory.Allocator) *array.Uint64
• func NewUintBuilder(a *memory.Allocator) *array.Uint64Builder
• func StringSlice(arr *array.Binary, i, j int) *array.Binary
• func UintSlice(arr *array.Uint64, i, j int) *array.Uint64
• type TableBuffer
  • func (t *TableBuffer) Bools(j int) *array.Boolean
  • func (t *TableBuffer) Cols() []flux.ColMeta
  • func (t *TableBuffer) Floats(j int) *array.Float64
  • func (t *TableBuffer) Ints(j int) *array.Int64
  • func (t *TableBuffer) Key() flux.GroupKey
  • func (t *TableBuffer) Len() int
  • func (t *TableBuffer) Release()
  • func (t *TableBuffer) Retain()
  • func (t *TableBuffer) Strings(j int) *array.Binary
  • func (t *TableBuffer) Times(j int) *array.Int64
  • func (t *TableBuffer) UInts(j int) *array.Uint64
  • func (t *TableBuffer) Validate() error

Functions

func AppendBool

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

AppendBool will append a bool to a compatible builder.

func AppendFloat

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

AppendFloat will append a float64 to a compatible builder.

func AppendInt

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

AppendInt will append an int64 to a compatible builder.

func AppendString

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

AppendString will append a string to a compatible builder.

func AppendTime

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

AppendTime will append a Time value to a compatible builder.

func AppendUint

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

AppendUint will append a uint64 to a compatible builder.

func AppendValue

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

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

func FloatSlice

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

func IntSlice

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

func NewAllocator

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

func NewBool

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

func NewBoolBuilder

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

func NewBuilder

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

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

func NewFloatBuilder

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

func NewInt

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

func NewIntBuilder

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

func NewString

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

func NewStringBuilder

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

func NewUint

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

func NewUintBuilder

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

func StringSlice

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

func UintSlice

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

Types

type TableBuffer

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

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

func (*TableBuffer) Cols

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

func (*TableBuffer) Floats

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

func (*TableBuffer) Ints

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

func (*TableBuffer) Key

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

func (*TableBuffer) Len

func (t *TableBuffer) Len() int

func (*TableBuffer) Release

func (t *TableBuffer) Release()

func (*TableBuffer) Retain

func (t *TableBuffer) Retain()

func (*TableBuffer) Strings

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

func (*TableBuffer) Times

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

func (*TableBuffer) UInts

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

func (*TableBuffer) Validate

func (t *TableBuffer) Validate() error

Validate will validate that this TableBuffer has the proper structure.