Versions in this module Expand all Collapse all v9 v9.0.0 Jul 29, 2022 Changes in this version + const UnknownLength + var ErrEmpty = errors.New("cannot traverse empty field path") + var ErrIndexRange = errors.New("index out of range") + var ErrInvalid = errors.New("field ref invalid") + var ErrMultipleMatches = errors.New("multiple matches") + var ErrNoChildren = errors.New("trying to get child of type with no children") + var ErrNoMatch = errors.New("no match") + func SerializeExpr(expr Expression, mem memory.Allocator) (*memory.Buffer, error) + func SerializeOptions(opts FunctionOptions, mem memory.Allocator) (*memory.Buffer, error) + type ArithmeticOptions struct + CheckOverflow bool + func (ArithmeticOptions) TypeName() string + type ArrayDatum struct + Value arrow.ArrayData + func (ArrayDatum) Kind() DatumKind + func (ArrayDatum) Shape() ValueShape + func (d *ArrayDatum) Chunks() []arrow.Array + func (d *ArrayDatum) Descr() ValueDescr + func (d *ArrayDatum) Equals(other Datum) bool + func (d *ArrayDatum) Len() int64 + func (d *ArrayDatum) MakeArray() arrow.Array + func (d *ArrayDatum) NullN() int64 + func (d *ArrayDatum) Release() + func (d *ArrayDatum) String() string + func (d *ArrayDatum) ToScalar() (scalar.Scalar, error) + func (d *ArrayDatum) Type() arrow.DataType + type ArrayLikeDatum interface + Chunks func() []arrow.Array + Descr func() ValueDescr + NullN func() int64 + Shape func() ValueShape + Type func() arrow.DataType + type Call struct + func (c *Call) Bind(ctx context.Context, mem memory.Allocator, schema *arrow.Schema) (Expression, error) + func (c *Call) Descr() ValueDescr + func (c *Call) Equals(other Expression) bool + func (c *Call) FieldRef() *FieldRef + func (c *Call) Hash() uint64 + func (c *Call) IsBound() bool + func (c *Call) IsNullLiteral() bool + func (c *Call) IsSatisfiable() bool + func (c *Call) IsScalarExpr() bool + func (c *Call) Release() + func (c *Call) String() string + func (c *Call) Type() arrow.DataType + type CastOptions struct + AllowDecimalTruncate bool + AllowFloatTruncate bool + AllowIntOverflow bool + AllowInvalidUtf8 bool + AllowTimeOverflow bool + AllowTimeTruncate bool + ToType arrow.DataType + func DefaultCastOptions(safe bool) *CastOptions + func NewCastOptions(dt arrow.DataType, safe bool) *CastOptions + func (CastOptions) TypeName() string + type ChunkedDatum struct + Value *arrow.Chunked + func (ChunkedDatum) Kind() DatumKind + func (ChunkedDatum) Shape() ValueShape + func (d *ChunkedDatum) Chunks() []arrow.Array + func (d *ChunkedDatum) Descr() ValueDescr + func (d *ChunkedDatum) Equals(other Datum) bool + func (d *ChunkedDatum) Len() int64 + func (d *ChunkedDatum) NullN() int64 + func (d *ChunkedDatum) Release() + func (d *ChunkedDatum) String() string + func (d *ChunkedDatum) Type() arrow.DataType + type CollectionDatum []Datum + func (CollectionDatum) Kind() DatumKind + func (c CollectionDatum) Equals(other Datum) bool + func (c CollectionDatum) Len() int64 + func (c CollectionDatum) Release() + func (c CollectionDatum) String() string + type Datum interface + Equals func(Datum) bool + Kind func() DatumKind + Len func() int64 + Release func() + func NewDatum(value interface{}) Datum + type DatumKind int + const KindArray + const KindChunked + const KindCollection + const KindNone + const KindRecord + const KindScalar + const KindTable + func (i DatumKind) String() string + type EmptyDatum struct + func (EmptyDatum) Equals(other Datum) bool + func (EmptyDatum) Kind() DatumKind + func (EmptyDatum) Len() int64 + func (EmptyDatum) Release() + func (EmptyDatum) String() string + type Expression interface + Bind func(context.Context, memory.Allocator, *arrow.Schema) (Expression, error) + Descr func() ValueDescr + Equals func(Expression) bool + FieldRef func() *FieldRef + Hash func() uint64 + IsBound func() bool + IsNullLiteral func() bool + IsSatisfiable func() bool + IsScalarExpr func() bool + Release func() + Type func() arrow.DataType + func And(lhs, rhs Expression, ops ...Expression) Expression + func Cast(ex Expression, dt arrow.DataType) Expression + func DeserializeExpr(mem memory.Allocator, buf *memory.Buffer) (Expression, error) + func Equal(lhs, rhs Expression) Expression + func Greater(lhs, rhs Expression) Expression + func GreaterEqual(lhs, rhs Expression) Expression + func IsNull(lhs Expression, nanIsNull bool) Expression + func IsValid(lhs Expression) Expression + func Less(lhs, rhs Expression) Expression + func LessEqual(lhs, rhs Expression) Expression + func NewCall(name string, args []Expression, opts FunctionOptions) Expression + func NewFieldRef(field string) Expression + func NewLiteral(arg interface{}) Expression + func NewRef(ref FieldRef) Expression + func Not(expr Expression) Expression + func NotEqual(lhs, rhs Expression) Expression + func NullLiteral(dt arrow.DataType) Expression + func Or(lhs, rhs Expression, ops ...Expression) Expression + func Project(values []Expression, names []string) Expression + type FieldPath []int + func (f FieldPath) Get(s *arrow.Schema) (*arrow.Field, error) + func (f FieldPath) GetColumn(batch arrow.Record) (arrow.Array, error) + func (f FieldPath) GetField(field arrow.Field) (*arrow.Field, error) + func (f FieldPath) GetFieldFromSlice(fields []arrow.Field) (*arrow.Field, error) + func (f FieldPath) GetFieldFromType(typ arrow.DataType) (*arrow.Field, error) + func (f FieldPath) String() string + type FieldRef struct + func FieldRefIndex(i int) FieldRef + func FieldRefList(elems ...interface{}) FieldRef + func FieldRefName(n string) FieldRef + func FieldRefPath(p FieldPath) FieldRef + func NewFieldRefFromDotPath(dotpath string) (out FieldRef, err error) + func (f *FieldRef) Equals(other FieldRef) bool + func (f *FieldRef) FieldPath() FieldPath + func (f *FieldRef) IsFieldPath() bool + func (f *FieldRef) IsName() bool + func (f *FieldRef) IsNested() bool + func (f *FieldRef) Name() string + func (f FieldRef) FindAll(fields []arrow.Field) []FieldPath + func (f FieldRef) FindAllField(field arrow.Field) []FieldPath + func (f FieldRef) FindOne(schema *arrow.Schema) (FieldPath, error) + func (f FieldRef) FindOneOrNone(schema *arrow.Schema) (FieldPath, error) + func (f FieldRef) FindOneOrNoneRecord(root arrow.Record) (FieldPath, error) + func (f FieldRef) GetAllColumns(root arrow.Record) ([]arrow.Array, error) + func (f FieldRef) GetOneColumnOrNone(root arrow.Record) (arrow.Array, error) + func (f FieldRef) GetOneField(schema *arrow.Schema) (*arrow.Field, error) + func (f FieldRef) GetOneOrNone(schema *arrow.Schema) (*arrow.Field, error) + func (f FieldRef) Hash(seed maphash.Seed) uint64 + func (f FieldRef) String() string + type FilterOptions struct + NullSelection NullSelectionBehavior + func (FilterOptions) TypeName() string + type FunctionOptions interface + TypeName func() string + type FunctionOptionsEqual interface + Equals func(FunctionOptions) bool + type Literal struct + Literal Datum + func (Literal) FieldRef() *FieldRef + func (l *Literal) Bind(ctx context.Context, mem memory.Allocator, schema *arrow.Schema) (Expression, error) + func (l *Literal) Descr() ValueDescr + func (l *Literal) Equals(other Expression) bool + func (l *Literal) Hash() uint64 + func (l *Literal) IsBound() bool + func (l *Literal) IsNullLiteral() bool + func (l *Literal) IsSatisfiable() bool + func (l *Literal) IsScalarExpr() bool + func (l *Literal) Release() + func (l *Literal) String() string + func (l *Literal) Type() arrow.DataType + type MakeStructOptions struct + FieldMetadata []*arrow.Metadata + FieldNames []string + FieldNullability []bool + func (MakeStructOptions) TypeName() string + type NullOptions struct + NanIsNull bool + func (NullOptions) TypeName() string + type NullSelectionBehavior int8 + const DropNulls + const EmitNulls + type Parameter struct + func (Parameter) IsNullLiteral() bool + func (p *Parameter) Bind(ctx context.Context, mem memory.Allocator, schema *arrow.Schema) (Expression, error) + func (p *Parameter) Descr() ValueDescr + func (p *Parameter) Equals(other Expression) bool + func (p *Parameter) FieldRef() *FieldRef + func (p *Parameter) Hash() uint64 + func (p *Parameter) IsBound() bool + func (p *Parameter) IsSatisfiable() bool + func (p *Parameter) IsScalarExpr() bool + func (p *Parameter) Release() + func (p *Parameter) String() string + func (p *Parameter) Type() arrow.DataType + type RecordDatum struct + Value arrow.Record + func (RecordDatum) Kind() DatumKind + func (RecordDatum) String() string + func (r *RecordDatum) Equals(other Datum) bool + func (r *RecordDatum) Len() int64 + func (r *RecordDatum) Release() + func (r *RecordDatum) Schema() *arrow.Schema + type ScalarDatum struct + Value scalar.Scalar + func (ScalarDatum) Chunks() []arrow.Array + func (ScalarDatum) Kind() DatumKind + func (ScalarDatum) Len() int64 + func (ScalarDatum) Shape() ValueShape + func (d *ScalarDatum) Descr() ValueDescr + func (d *ScalarDatum) Equals(other Datum) bool + func (d *ScalarDatum) NullN() int64 + func (d *ScalarDatum) Release() + func (d *ScalarDatum) String() string + func (d *ScalarDatum) ToScalar() (scalar.Scalar, error) + func (d *ScalarDatum) Type() arrow.DataType + type SetLookupOptions struct + SkipNulls bool + ValueSet Datum + func (SetLookupOptions) TypeName() string + func (s *SetLookupOptions) Equals(other FunctionOptions) bool + func (s *SetLookupOptions) FromStructScalar(sc *scalar.Struct) error + func (s *SetLookupOptions) Release() + type StrptimeOptions struct + Format string + Unit arrow.TimeUnit + func (StrptimeOptions) TypeName() string + type TableDatum struct + Value arrow.Table + func (TableDatum) Kind() DatumKind + func (TableDatum) String() string + func (d *TableDatum) Equals(other Datum) bool + func (d *TableDatum) Len() int64 + func (d *TableDatum) Release() + func (d *TableDatum) Schema() *arrow.Schema + type TableLikeDatum interface + Schema func() *arrow.Schema + type ValueDescr struct + Shape ValueShape + Type arrow.DataType + func (v *ValueDescr) String() string + type ValueShape int8 + const ShapeAny + const ShapeArray + const ShapeScalar + func (i ValueShape) String() string Other modules containing this package github.com/apache/arrow/go/v11 github.com/apache/arrow/go/v12 github.com/apache/arrow/go/v13 github.com/apache/arrow/go/v14 github.com/apache/arrow/go/v15 github.com/apache/arrow/go/v16 github.com/apache/arrow/go/v7 github.com/apache/arrow/go/v8