Versions in this module Expand all Collapse all v16 v16.1.0 May 9, 2024 v16.0.0 Apr 16, 2024 Changes in this version + const ArrowExtTypesUri + const SubstraitArithmeticFuncsURI + const SubstraitComparisonFuncsURI + const SubstraitDefaultURIPrefix + const TimestampTzTimezone + var DefaultExtensionIDRegistry = NewExtensionIDRegistry() + func ExecuteScalarExpression(ctx context.Context, inputSchema *arrow.Schema, expression expr.Expression, ...) (compute.Datum, error) + func ExecuteScalarSubstrait(ctx context.Context, expression *expr.Extended, partialInput compute.Datum) (compute.Datum, error) + func FieldsFromSubstrait(typeList []types.Type, nextName func() string, ext ExtensionIDSet) (out []arrow.Field, err error) + func FromSubstraitType(t types.Type, ext ExtensionIDSet) (arrow.DataType, bool, error) + func GetRefField(ref expr.ReferenceSegment, fields []arrow.Field) (*arrow.Field, error) + func GetRefSchema(ref expr.ReferenceSegment, schema *arrow.Schema) (*arrow.Field, error) + func GetReferencedValue(mem memory.Allocator, ref expr.ReferenceSegment, value compute.Datum, ...) (compute.Datum, error) + func GetScalar(ref expr.ReferenceSegment, s scalar.Scalar, mem memory.Allocator, ...) (scalar.Scalar, error) + func IsNullable(t types.Type) bool + func NewFieldRef(ref compute.FieldRef, schema *arrow.Schema, ext ExtensionIDSet) (*expr.FieldReference, error) + func NewFieldRefFromDotPath(dotpath string, rootSchema *arrow.Schema) (expr.ReferenceSegment, error) + func NewScalarCall(reg ExtensionIDSet, fn string, opts []*types.FunctionOption, ...) (*expr.ScalarFunction, error) + func RefFromFieldPath(field compute.FieldPath) expr.ReferenceSegment + func ToArrowSchema(base types.NamedStruct, ext ExtensionIDSet) (*arrow.Schema, error) + func ToSubstraitType(dt arrow.DataType, nullable bool, ext ExtensionIDSet) (types.Type, error) + func WithExtensionIDSet(ctx context.Context, ext ExtensionIDSet) context.Context + func WithExtensionRegistry(ctx context.Context, reg *ExtensionIDRegistry) context.Context + type Builder interface + type ExprBuilder struct + func NewExprBuilder(extSet ExtensionIDSet) ExprBuilder + func (*ExprBuilder) Must(b Builder, err error) Builder + func (e *ExprBuilder) CallScalar(fn string, opts []*types.FunctionOption, args ...expr.FuncArgBuilder) (Builder, error) + func (e *ExprBuilder) Cast(from Builder, to arrow.DataType) (Builder, error) + func (e *ExprBuilder) FieldIndex(i int) Builder + func (e *ExprBuilder) FieldPath(path compute.FieldPath) Builder + func (e *ExprBuilder) FieldRef(field string) Builder + func (e *ExprBuilder) FieldRefList(elems ...any) Builder + func (e *ExprBuilder) Literal(l expr.Literal) Builder + func (e *ExprBuilder) MustCallScalar(fn string, opts []*types.FunctionOption, args ...expr.FuncArgBuilder) Builder + func (e *ExprBuilder) SetInputSchema(s *arrow.Schema) error + func (e *ExprBuilder) WrapLiteral(l expr.Literal, err error) Builder + type ExtensionIDRegistry struct + func GetExtensionRegistry(ctx context.Context) *ExtensionIDRegistry + func NewExtensionIDRegistry() *ExtensionIDRegistry + func (e *ExtensionIDRegistry) AddArrowToSubstrait(name string, fn arrowToSubstrait) error + func (e *ExtensionIDRegistry) AddSubstraitScalarToArrow(id extensions.ID, toArrow substraitToArrow) error + func (e *ExtensionIDRegistry) GetArrowToSubstrait(name string) (conv arrowToSubstrait, ok bool) + func (e *ExtensionIDRegistry) GetIDByType(typ arrow.DataType) (extensions.ID, bool) + func (e *ExtensionIDRegistry) GetSubstraitScalarToArrow(id extensions.ID) (substraitToArrow, bool) + func (e *ExtensionIDRegistry) GetTypeByID(id extensions.ID) (arrow.DataType, bool) + func (e *ExtensionIDRegistry) RegisterType(id extensions.ID, dt arrow.DataType) error + type ExtensionIDSet interface + DecodeFunction func(ref uint32) (extensions.ID, substraitToArrow, bool) + DecodeTypeArrow func(anchor uint32) (extensions.ID, arrow.DataType, bool) + EncodeType func(dt arrow.DataType) (extensions.ID, uint32, bool) + EncodeTypeVariation func(dt arrow.DataType) (extensions.ID, uint32, bool) + GetArrowRegistry func() *ExtensionIDRegistry + GetSubstraitRegistry func() expr.ExtensionRegistry + func GetExtensionIDSet(ctx context.Context) ExtensionIDSet + func NewDefaultExtensionSet() ExtensionIDSet + func NewExtensionSet(set expr.ExtensionRegistry, reg *ExtensionIDRegistry) ExtensionIDSet + func NewExtensionSetDefault(set expr.ExtensionRegistry) ExtensionIDSet Other modules containing this package github.com/apache/arrow/go/v13 github.com/apache/arrow/go/v14 github.com/apache/arrow/go/v15