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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AppendBool ¶ added in v0.49.0
AppendBool will append a bool to a compatible builder.
func AppendFloat ¶ added in v0.49.0
AppendFloat will append a float64 to a compatible builder.
func AppendString ¶ added in v0.49.0
AppendString will append a string to a compatible builder.
func AppendTime ¶ added in v0.49.0
AppendTime will append a Time value to a compatible builder.
func AppendUint ¶ added in v0.49.0
AppendUint will append a uint64 to a compatible builder.
func AppendValue ¶ added in v0.49.0
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 ¶ added in v0.38.0
func NewAllocator(a *memory.Allocator) arrowmemory.Allocator
func NewBoolBuilder ¶
func NewBoolBuilder(a *memory.Allocator) *array.BooleanBuilder
func NewBuilder ¶ added in v0.49.0
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.Float64Builder
func NewIntBuilder ¶
func NewIntBuilder(a *memory.Allocator) *array.Int64Builder
func NewStringBuilder ¶
func NewStringBuilder(a *memory.Allocator) *array.BinaryBuilder
func NewUintBuilder ¶
func NewUintBuilder(a *memory.Allocator) *array.Uint64Builder
Types ¶
type TableBuffer ¶ added in v0.49.0
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) Cols ¶ added in v0.49.0
func (t *TableBuffer) Cols() []flux.ColMeta
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) Validate ¶ added in v0.49.0
func (t *TableBuffer) Validate() error
Validate will validate that this TableBuffer has the proper structure.