arrow

Documentation

Index

• func AppendBools(tbl TableAppender, j int, vs *array.Boolean) error
• func AppendFloats(tbl TableAppender, j int, vs *array.Float64) error
• func AppendInts(tbl TableAppender, j int, vs *array.Int64) error
• func AppendStrings(tbl TableAppender, j int, vs *array.Binary) error
• func AppendTimes(tbl TableAppender, j int, vs *array.Int64) error
• func AppendUInts(tbl TableAppender, j int, vs *array.Uint64) error
• func BoolSlice(arr *array.Boolean, i, j int) *array.Boolean
• func ColReader(cr flux.ArrowColReader) flux.ColReader
• func FloatSlice(arr *array.Float64, i, j int) *array.Float64
• func IntSlice(arr *array.Int64, i, j int) *array.Int64
• func NewBool(vs []bool, alloc *memory.Allocator) *array.Boolean
• func NewBoolBuilder(a *memory.Allocator) *array.BooleanBuilder
• 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 TableAppender

Functions

func AppendBools

func AppendBools(tbl TableAppender, j int, vs *array.Boolean) error

func AppendFloats

func AppendFloats(tbl TableAppender, j int, vs *array.Float64) error

func AppendInts

func AppendInts(tbl TableAppender, j int, vs *array.Int64) error

func AppendStrings

func AppendStrings(tbl TableAppender, j int, vs *array.Binary) error

func AppendTimes

func AppendTimes(tbl TableAppender, j int, vs *array.Int64) error

func AppendUInts

func AppendUInts(tbl TableAppender, j int, vs *array.Uint64) error

func BoolSlice

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

func ColReader

func ColReader(cr flux.ArrowColReader) flux.ColReader

ColReader creates a wrapper around an ArrowColReader that will implement the flux.ColReader interface. If the relevant type cannot be returned directly from the arrow array, this reader will lazily memoize a copy of the array as a slice.

This method will be removed when the flux.ColReader interface is replaced by the flux.ArrowColReader interface.

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 NewBool

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

func NewBoolBuilder

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

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 TableAppender

type TableAppender interface {
	AppendBools(j int, values []bool) error
	AppendInts(j int, values []int64) error
	AppendUInts(j int, values []uint64) error
	AppendFloats(j int, values []float64) error
	AppendStrings(j int, values []string) error
	AppendTimes(j int, values []values.Time) error
}