Versions in this module Expand all Collapse all v0 v0.0.1 Mar 23, 2024 Changes in this version + func GetGroupsAndOrderedSetRanges(firstGroup []any, arrs []arrow.Array) (*Int64Heap, *Int64Heap, []any, error) + func MakeNullArray(mem memory.Allocator, dt arrow.DataType, len int) arrow.Array + func MergeRecords(mem memory.Allocator, records []arrow.Record, orderByCols []SortingColumn, ...) (arrow.Record, error) + func SortRecord(r arrow.Record, columns []SortingColumn) (*array.Int32, error) + func Take(ctx context.Context, r arrow.Record, indices *array.Int32) (arrow.Record, error) + func TakeColumn(ctx context.Context, a arrow.Array, idx int, arr []arrow.Array, ...) error + func TakeDictColumn(ctx context.Context, a *array.Dictionary, idx int, arr []arrow.Array, ...) error + type ArrayConcatenator struct + func (c *ArrayConcatenator) Add(arr arrow.Array) + func (c *ArrayConcatenator) Len() int + func (c *ArrayConcatenator) NewArray(mem memory.Allocator) (arrow.Array, error) + func (c *ArrayConcatenator) Release() + type Direction uint + const Ascending + const Descending + type Int64Heap []int64 + func (h *Int64Heap) Pop() any + func (h *Int64Heap) PopNextNotEqual(compare int64) (int64, bool) + func (h *Int64Heap) Push(x any) + func (h *Int64Heap) Unwrap(scratch []int64) []int64 + func (h Int64Heap) Len() int + func (h Int64Heap) Less(i, j int) bool + func (h Int64Heap) Swap(i, j int) + type SortingColumn struct + Direction Direction + Index int + NullsFirst bool + type VirtualNullArray struct + func MakeVirtualNullArray(dt arrow.DataType, len int) VirtualNullArray + func (n VirtualNullArray) Data() arrow.ArrayData + func (n VirtualNullArray) DataType() arrow.DataType + func (n VirtualNullArray) GetOneForMarshal(_ int) any + func (n VirtualNullArray) IsNull(_ int) bool + func (n VirtualNullArray) IsValid(_ int) bool + func (n VirtualNullArray) Len() int + func (n VirtualNullArray) MarshalJSON() ([]byte, error) + func (n VirtualNullArray) NullBitmapBytes() []byte + func (n VirtualNullArray) NullN() int + func (n VirtualNullArray) Release() + func (n VirtualNullArray) Retain() + func (n VirtualNullArray) String() string + func (n VirtualNullArray) ValueStr(_ int) string