Versions in this module Expand all Collapse all v18 v18.0.0 Oct 15, 2024 Changes in this version + func ArrayFromSliceWithValid[T arrow.NumericType | bool](mem memory.Allocator, data []T, valid []bool) arrow.Array + func ArrayFromSlice[T arrow.NumericType | bool](mem memory.Allocator, data []T) arrow.Array + func FillZeroLength(dt arrow.DataType, span *ArraySpan) + func GetAllocator(ctx context.Context) memory.Allocator + func GetSpanOffsets[T int32 | int64](span *ArraySpan, i int) []T + func GetSpanValues[T arrow.FixedWidthType](span *ArraySpan, i int) []T + func HashCombine(seed, value uint64) uint64 + func Max[T constraints.Ordered](a, b T) T + func Min[T constraints.Ordered](a, b T) T + func PromoteExecSpanScalars(span ExecSpan) + func RechunkArraysConsistently(groups [][]arrow.Array) [][]arrow.Array + func WithAllocator(ctx context.Context, mem memory.Allocator) context.Context + type ArrayIter interface + Next func() T + func NewBoolIter(arr *ArraySpan) ArrayIter[bool] + func NewFSBIter(arr *ArraySpan) ArrayIter[[]byte] + func NewPrimitiveIter[T arrow.FixedWidthType](arr *ArraySpan) ArrayIter[T] + func NewVarBinaryIter[OffsetT int32 | int64](arr *ArraySpan) ArrayIter[[]byte] + type ArrayKernelExec = func(*KernelCtx, *ExecSpan, *ExecResult) error + type ArraySpan struct + Buffers [3]BufferSpan + Children []ArraySpan + Len int64 + Nulls int64 + Offset int64 + Scratch [2]uint64 + Type arrow.DataType + func (a *ArraySpan) Dictionary() *ArraySpan + func (a *ArraySpan) FillFromScalar(val scalar.Scalar) + func (a *ArraySpan) GetBuffer(idx int) *memory.Buffer + func (a *ArraySpan) MakeArray() arrow.Array + func (a *ArraySpan) MakeData() arrow.ArrayData + func (a *ArraySpan) MayHaveNulls() bool + func (a *ArraySpan) NumBuffers() int + func (a *ArraySpan) Release() + func (a *ArraySpan) SetDictionary(span *ArraySpan) + func (a *ArraySpan) SetMembers(data arrow.ArrayData) + func (a *ArraySpan) SetSlice(off, length int64) + func (a *ArraySpan) TakeOwnership(data arrow.ArrayData) + func (a *ArraySpan) UpdateNullCount() int64 + type BoolIter struct + Rdr *bitutil.BitmapReader + func (b *BoolIter) Next() (out bool) + type BufferSpan struct + Buf []byte + Owner *memory.Buffer + SelfAlloc bool + func (b *BufferSpan) SetBuffer(buf *memory.Buffer) + func (b *BufferSpan) WrapBuffer(buf *memory.Buffer) + type ChunkResolver struct + func NewChunkResolver(chunks []arrow.Array) *ChunkResolver + func (c *ChunkResolver) Resolve(idx int64) (chunk, index int64) + type ChunkedExec func(*KernelCtx, []*arrow.Chunked, *ExecResult) ([]*ExecResult, error) + type ExecResult = ArraySpan + type ExecSpan struct + Len int64 + Values []ExecValue + type ExecValue struct + Array ArraySpan + Scalar scalar.Scalar + func (e *ExecValue) IsArray() bool + func (e *ExecValue) IsScalar() bool + func (e *ExecValue) Type() arrow.DataType + type FSBIter struct + Data []byte + Pos int64 + Width int + func (f *FSBIter) Next() []byte + type FinalizeFunc func(*KernelCtx, []*ArraySpan) ([]*ArraySpan, error) + type InputKind int8 + const InputAny + const InputExact + const InputUseMatcher + type InputType struct + Kind InputKind + Matcher TypeMatcher + Type arrow.DataType + func NewExactInput(dt arrow.DataType) InputType + func NewIDInput(id arrow.Type) InputType + func NewMatchedInput(match TypeMatcher) InputType + func (it *InputType) Equals(other *InputType) bool + func (it InputType) Hash() uint64 + func (it InputType) MatchID() arrow.Type + func (it InputType) Matches(dt arrow.DataType) bool + func (it InputType) String() string + type Kernel interface + GetInitFn func() KernelInitFn + GetSig func() *KernelSignature + type KernelCtx struct + Ctx context.Context + Kernel Kernel + State KernelState + func (k *KernelCtx) Allocate(bufsize int) *memory.Buffer + func (k *KernelCtx) AllocateBitmap(nbits int64) *memory.Buffer + type KernelInitArgs struct + Inputs []arrow.DataType + Kernel Kernel + Options any + type KernelInitFn = func(*KernelCtx, KernelInitArgs) (KernelState, error) + type KernelSignature struct + InputTypes []InputType + IsVarArgs bool + OutType OutputType + func (k *KernelSignature) Hash() uint64 + func (k KernelSignature) Equals(other KernelSignature) bool + func (k KernelSignature) MatchesInputs(types []arrow.DataType) bool + func (k KernelSignature) String() string + type KernelState any + func OptionsInit[T any](_ *KernelCtx, args KernelInitArgs) (KernelState, error) + type MemAlloc int8 + const MemNoPrealloc + const MemPrealloc + type NonAggKernel interface + CanFillSlices func() bool + Exec func(*KernelCtx, *ExecSpan, *ExecResult) error + GetMemAlloc func() MemAlloc + GetNullHandling func() NullHandling + type NullHandling int8 + const NullComputedNoPrealloc + const NullComputedPrealloc + const NullIntersection + const NullNoOutput + type OutputType struct + Kind ResolveKind + Resolver TypeResolver + Type arrow.DataType + func NewComputedOutputType(resolver TypeResolver) OutputType + func NewOutputType(dt arrow.DataType) OutputType + func (o OutputType) Resolve(ctx *KernelCtx, types []arrow.DataType) (arrow.DataType, error) + func (o OutputType) String() string + type PrimitiveIter struct + Values []T + func (p *PrimitiveIter[T]) Next() (v T) + type ResolveKind int8 + const ResolveComputed + const ResolveFixed + type ScalarKernel struct + CanWriteIntoSlices bool + ExecFn ArrayKernelExec + MemAlloc MemAlloc + NullHandling NullHandling + func NewScalarKernel(in []InputType, out OutputType, exec ArrayKernelExec, init KernelInitFn) ScalarKernel + func NewScalarKernelWithSig(sig *KernelSignature, exec ArrayKernelExec, init KernelInitFn) ScalarKernel + func (k ScalarKernel) GetInitFn() KernelInitFn + func (k ScalarKernel) GetSig() *KernelSignature + func (s *ScalarKernel) Exec(ctx *KernelCtx, sp *ExecSpan, out *ExecResult) error + func (s ScalarKernel) CanFillSlices() bool + func (s ScalarKernel) GetMemAlloc() MemAlloc + func (s ScalarKernel) GetNullHandling() NullHandling + type TypeMatcher interface + Equals func(other TypeMatcher) bool + Matches func(typ arrow.DataType) bool + func BinaryLike() TypeMatcher + func DurationTypeUnit(unit arrow.TimeUnit) TypeMatcher + func FixedSizeBinaryLike() TypeMatcher + func Integer() TypeMatcher + func LargeBinaryLike() TypeMatcher + func Primitive() TypeMatcher + func RunEndEncoded(runEndsMatcher, encodedMatcher TypeMatcher) TypeMatcher + func SameTypeID(id arrow.Type) TypeMatcher + func Time32TypeUnit(unit arrow.TimeUnit) TypeMatcher + func Time64TypeUnit(unit arrow.TimeUnit) TypeMatcher + func TimestampTypeUnit(unit arrow.TimeUnit) TypeMatcher + type TypeResolver = func(*KernelCtx, []arrow.DataType) (arrow.DataType, error) + type VarBinaryIter struct + Data []byte + Offsets []OffsetT + Pos int64 + func (v *VarBinaryIter[OffsetT]) Next() []byte + type VectorKernel struct + CanExecuteChunkWise bool + CanWriteIntoSlices bool + ExecChunked ChunkedExec + ExecFn ArrayKernelExec + Finalize FinalizeFunc + MemAlloc MemAlloc + NullHandling NullHandling + OutputChunked bool + func NewVectorKernel(inTypes []InputType, outType OutputType, exec ArrayKernelExec, ...) VectorKernel + func NewVectorKernelWithSig(sig *KernelSignature, exec ArrayKernelExec, init KernelInitFn) VectorKernel + func (k VectorKernel) GetInitFn() KernelInitFn + func (k VectorKernel) GetSig() *KernelSignature + func (s *VectorKernel) Exec(ctx *KernelCtx, sp *ExecSpan, out *ExecResult) error + func (s VectorKernel) CanFillSlices() bool + func (s VectorKernel) GetMemAlloc() MemAlloc + func (s VectorKernel) GetNullHandling() NullHandling v18.0.0-rc0 Oct 15, 2024
Go to main page