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 Empty(typ flux.ColType) array.Array
- func FloatSlice(arr *array.Float, i, j int) *array.Float
- func IntSlice(arr *array.Int, i, j int) *array.Int
- 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.Float
- func NewFloatBuilder(a memory.Allocator) *array.FloatBuilder
- func NewInt(vs []int64, alloc memory.Allocator) *array.Int
- func NewIntBuilder(a memory.Allocator) *array.IntBuilder
- func NewString(vs []string, alloc memory.Allocator) *array.String
- func NewStringBuilder(a memory.Allocator) *array.StringBuilder
- func NewUint(vs []uint64, alloc memory.Allocator) *array.Uint
- func NewUintBuilder(a memory.Allocator) *array.UintBuilder
- func Nulls(typ flux.ColType, n int, mem memory.Allocator) array.Array
- func Repeat(colType flux.ColType, v values.Value, n int, mem memory.Allocator) array.Array
- func Slice(arr array.Array, i, j int64) array.Array
- func StringSlice(arr *array.String, i, j int) *array.String
- func UintSlice(arr *array.Uint, i, j int) *array.Uint
- type TableBuffer
- func (t *TableBuffer) Bools(j int) *array.Boolean
- func (t *TableBuffer) Cols() []flux.ColMeta
- func (t *TableBuffer) Floats(j int) *array.Float
- func (t *TableBuffer) Ints(j int) *array.Int
- 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.String
- func (t *TableBuffer) Times(j int) *array.Int
- func (t *TableBuffer) UInts(j int) *array.Uint
- func (t *TableBuffer) Validate() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AppendBool ¶
AppendBool will append a bool to a compatible builder.
func AppendFloat ¶
AppendFloat will append a float64 to a compatible builder.
func AppendString ¶
AppendString will append a string to a compatible builder.
func AppendTime ¶
AppendTime will append a Time value to a compatible builder.
func AppendUint ¶
AppendUint will append a uint64 to a compatible builder.
func AppendValue ¶
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 NewAllocator ¶
func NewAllocator(a memory.Allocator) arrowmemory.Allocator
func NewBoolBuilder ¶
func NewBoolBuilder(a memory.Allocator) *array.BooleanBuilder
func NewBuilder ¶
NewBuilder constructs a new builder for the given column type. The allocator passed in must be non-nil.
func NewFloatBuilder ¶
func NewFloatBuilder(a memory.Allocator) *array.FloatBuilder
func NewIntBuilder ¶
func NewIntBuilder(a memory.Allocator) *array.IntBuilder
func NewStringBuilder ¶
func NewStringBuilder(a memory.Allocator) *array.StringBuilder
func NewUintBuilder ¶
func NewUintBuilder(a memory.Allocator) *array.UintBuilder
func Nulls ¶
Nulls creates an array of entirely nulls. It uses the ColType to determine which builder to use.
func Slice ¶
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.
Types ¶
type TableBuffer ¶
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 EmptyBuffer ¶
func EmptyBuffer(key flux.GroupKey, cols []flux.ColMeta) TableBuffer
EmptyBuffer properly constructs an empty TableBuffer.
func (*TableBuffer) Cols ¶
func (t *TableBuffer) Cols() []flux.ColMeta
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) Validate ¶
func (t *TableBuffer) Validate() error
Validate will validate that this TableBuffer has the proper structure.
Source Files