agg

package

Go to main page

Versions in this module

v1

v1.1.3

Apr 15, 2024

v1.1.2

Apr 2, 2024

v1.1.1

Feb 2, 2024

v1.1.0

Dec 29, 2023

Changes in this version

type Agg

+ SetPartialResult func(PartialResult any)

type AggStruct

+ Dup func() AggStruct

type UnaryAgg

+ PartialResult any

+ func (agg *UnaryAgg[T1, T2]) SetPartialResult(PartialResult any)

type UnaryDistAgg

+ PartialResult any

+ func (agg *UnaryDistAgg[T1, T2]) SetPartialResult(PartialResult any)

v1.0.2

Dec 21, 2023

v1.0.1

Dec 15, 2023

v1.0.0

Nov 13, 2023

Changes in this version

+ const GroupNotMatch

+ var IsWinOrderFun func(overloadID int64) bool

+ var NewAgg func(overloadID int64, isDistinct bool, inputTypes []types.Type) (Agg[any], error)

+ var NewAggWithConfig func(overloadID int64, isDistinct bool, inputTypes []types.Type, config any, ...) (Agg[any], error)

+ func InitAggFramework(...)

type Aggregate

+ Config []byte

v1.0.0-rc2

Oct 24, 2023

v1.0.0-rc1

Aug 24, 2023

v0

v0.8.1

Oct 9, 2023

v0.8.0

Jun 30, 2023

Changes in this version

+ const WinDenseRank

+ const WinRank

+ const WinRowNumber

+ var AnyValueSupported = []types.T

+ var AvgSupported = []types.T

+ var BitAndSupported = []types.T

+ var BitOrSupported = []types.T

+ var BitXorSupported = []types.T

+ var ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")

+ var MaxSupported = []types.T

+ var MedianSupported = []types.T

+ var MinSupported = []types.T

+ var StdDevPopSupported = []types.T

+ var SumSupported = []types.T

+ var VarianceSupported = []types.T

+ func DenseRankReturnType() types.Type

+ func RankReturnType() types.Type

+ func RowNumberReturnType() types.Type

+ type BitAndBinary struct

+ func NewBitAndBinary() *BitAndBinary

+ func (bab *BitAndBinary) Eval(vs [][]byte, err error) ([][]byte, error)

+ func (bab *BitAndBinary) Fill(gNum int64, v1, v2 []byte, _ int64, isNew, isNull bool) ([]byte, bool, error)

+ func (bab *BitAndBinary) Grows(_ int)

+ func (bab *BitAndBinary) MarshalBinary() ([]byte, error)

+ func (bab *BitAndBinary) Merge(gNum1, gNum2 int64, v1, v2 []byte, empty1, empty2 bool, _ any) ([]byte, bool, error)

+ func (bab *BitAndBinary) UnmarshalBinary(data []byte) error

+ type BitOrBinary struct

+ func NewBitOrBinary() *BitOrBinary

+ func (bab *BitOrBinary) Eval(vs [][]byte, err error) ([][]byte, error)

+ func (bab *BitOrBinary) Fill(gNum int64, v1, v2 []byte, _ int64, isNew, isNull bool) ([]byte, bool, error)

+ func (bab *BitOrBinary) Grows(_ int)

+ func (bab *BitOrBinary) MarshalBinary() ([]byte, error)

+ func (bab *BitOrBinary) Merge(gNum1, gNum2 int64, v1, v2 []byte, empty1, empty2 bool, _ any) ([]byte, bool, error)

+ func (bab *BitOrBinary) UnmarshalBinary(data []byte) error

+ type BitXorBinary struct

+ func NewBitXorBinary() *BitXorBinary

+ func (bab *BitXorBinary) Eval(vs [][]byte, err error) ([][]byte, error)

+ func (bab *BitXorBinary) Fill(gNum int64, v1, v2 []byte, _ int64, isNew, isNull bool) ([]byte, bool, error)

+ func (bab *BitXorBinary) Grows(_ int)

+ func (bab *BitXorBinary) MarshalBinary() ([]byte, error)

+ func (bab *BitXorBinary) Merge(gNum1, gNum2 int64, v1, v2 []byte, empty1, empty2 bool, _ any) ([]byte, bool, error)

+ func (bab *BitXorBinary) UnmarshalBinary(data []byte) error

type Count

+ func (c *Count[T1]) BatchFill(rs, _ any, start, count int64, vps []uint64, zs []int64, nsp *nulls.Nulls) error

type Decimal128Avg

+ Typ types.Type

type Decimal128Median

+ func (*Decimal128Median) Descriptor() ([]byte, []int)

+ func (*Decimal128Median) ProtoMessage()

+ func (m *Decimal128Median) Marshal() (dAtA []byte, err error)

+ func (m *Decimal128Median) MarshalTo(dAtA []byte) (int, error)

+ func (m *Decimal128Median) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Decimal128Median) ProtoSize() (n int)

+ func (m *Decimal128Median) Reset()

+ func (m *Decimal128Median) String() string

+ func (m *Decimal128Median) Unmarshal(dAtA []byte) error

+ func (m *Decimal128Median) XXX_DiscardUnknown()

+ func (m *Decimal128Median) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Decimal128Median) XXX_Merge(src proto.Message)

+ func (m *Decimal128Median) XXX_Size() int

+ func (m *Decimal128Median) XXX_Unmarshal(b []byte) error

+ type Decimal128SlicePB struct

+ Slice []github_com_matrixorigin_matrixone_pkg_container_types.Decimal128

+ func (*Decimal128SlicePB) Descriptor() ([]byte, []int)

+ func (*Decimal128SlicePB) ProtoMessage()

+ func (m *Decimal128SlicePB) Marshal() (dAtA []byte, err error)

+ func (m *Decimal128SlicePB) MarshalTo(dAtA []byte) (int, error)

+ func (m *Decimal128SlicePB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Decimal128SlicePB) ProtoSize() (n int)

+ func (m *Decimal128SlicePB) Reset()

+ func (m *Decimal128SlicePB) String() string

+ func (m *Decimal128SlicePB) Unmarshal(dAtA []byte) error

+ func (m *Decimal128SlicePB) XXX_DiscardUnknown()

+ func (m *Decimal128SlicePB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Decimal128SlicePB) XXX_Merge(src proto.Message)

+ func (m *Decimal128SlicePB) XXX_Size() int

+ func (m *Decimal128SlicePB) XXX_Unmarshal(b []byte) error

type Decimal64Avg

+ Typ types.Type

type Decimal64Median

+ func (*Decimal64Median) Descriptor() ([]byte, []int)

+ func (*Decimal64Median) ProtoMessage()

+ func (m *Decimal64Median) Marshal() (dAtA []byte, err error)

+ func (m *Decimal64Median) MarshalTo(dAtA []byte) (int, error)

+ func (m *Decimal64Median) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Decimal64Median) ProtoSize() (n int)

+ func (m *Decimal64Median) Reset()

+ func (m *Decimal64Median) String() string

+ func (m *Decimal64Median) Unmarshal(dAtA []byte) error

+ func (m *Decimal64Median) XXX_DiscardUnknown()

+ func (m *Decimal64Median) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Decimal64Median) XXX_Merge(src proto.Message)

+ func (m *Decimal64Median) XXX_Size() int

+ func (m *Decimal64Median) XXX_Unmarshal(b []byte) error

+ type Decimal64SlicePB struct

+ Slice []github_com_matrixorigin_matrixone_pkg_container_types.Decimal64

+ func (*Decimal64SlicePB) Descriptor() ([]byte, []int)

+ func (*Decimal64SlicePB) ProtoMessage()

+ func (m *Decimal64SlicePB) Marshal() (dAtA []byte, err error)

+ func (m *Decimal64SlicePB) MarshalTo(dAtA []byte) (int, error)

+ func (m *Decimal64SlicePB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Decimal64SlicePB) ProtoSize() (n int)

+ func (m *Decimal64SlicePB) Reset()

+ func (m *Decimal64SlicePB) String() string

+ func (m *Decimal64SlicePB) Unmarshal(dAtA []byte) error

+ func (m *Decimal64SlicePB) XXX_DiscardUnknown()

+ func (m *Decimal64SlicePB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Decimal64SlicePB) XXX_Merge(src proto.Message)

+ func (m *Decimal64SlicePB) XXX_Size() int

+ func (m *Decimal64SlicePB) XXX_Unmarshal(b []byte) error

+ type DenseRank struct

+ Ps [][]int64

+ func NewDenseRank() *DenseRank

+ func (r *DenseRank) BatchFill(rs, vs any, start, count int64, vps []uint64, zs []int64, nsp *nulls.Nulls) error

+ func (r *DenseRank) Eval(vs []int64, err error) ([]int64, error)

+ func (r *DenseRank) Fill(i int64, value int64, ov int64, z int64, isEmpty bool, isNull bool) (int64, bool, error)

+ func (r *DenseRank) Grows(_ int)

+ func (r *DenseRank) MarshalBinary() ([]byte, error)

+ func (r *DenseRank) Merge(xIndex int64, yIndex int64, x int64, y int64, xEmpty bool, yEmpty bool, ...) (int64, bool, error)

+ func (r *DenseRank) UnmarshalBinary(data []byte) error

type EncodeAgg

+ func (*EncodeAgg) Descriptor() ([]byte, []int)

+ func (*EncodeAgg) ProtoMessage()

+ func (m *EncodeAgg) GetDa() []byte

+ func (m *EncodeAgg) GetEs() []bool

+ func (m *EncodeAgg) GetInputTypes() []byte

+ func (m *EncodeAgg) GetIsCount() bool

+ func (m *EncodeAgg) GetOp() int

+ func (m *EncodeAgg) GetOutputType() []byte

+ func (m *EncodeAgg) GetPrivate() []byte

+ func (m *EncodeAgg) Marshal() (dAtA []byte, err error)

+ func (m *EncodeAgg) MarshalTo(dAtA []byte) (int, error)

+ func (m *EncodeAgg) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EncodeAgg) ProtoSize() (n int)

+ func (m *EncodeAgg) Reset()

+ func (m *EncodeAgg) String() string

+ func (m *EncodeAgg) Unmarshal(dAtA []byte) error

+ func (m *EncodeAgg) XXX_DiscardUnknown()

+ func (m *EncodeAgg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EncodeAgg) XXX_Merge(src proto.Message)

+ func (m *EncodeAgg) XXX_Size() int

+ func (m *EncodeAgg) XXX_Unmarshal(b []byte) error

type EncodeAggDistinct

+ InputTypes []types.Type

+ func (m *EncodeAggDistinct[T]) MarshalBinary() ([]byte, error)

+ func (m *EncodeAggDistinct[T]) UnmarshalBinary(data []byte) error

+ type EncodeAggDistinctPB struct

+ Da []byte

+ Es []bool

+ InputTypes []github_com_matrixorigin_matrixone_pkg_container_types.Type

+ IsCount bool

+ Op int

+ OutputType github_com_matrixorigin_matrixone_pkg_container_types.Type

+ Private []byte

+ func (*EncodeAggDistinctPB) Descriptor() ([]byte, []int)

+ func (*EncodeAggDistinctPB) ProtoMessage()

+ func (m *EncodeAggDistinctPB) GetDa() []byte

+ func (m *EncodeAggDistinctPB) GetEs() []bool

+ func (m *EncodeAggDistinctPB) GetIsCount() bool

+ func (m *EncodeAggDistinctPB) GetOp() int

+ func (m *EncodeAggDistinctPB) GetPrivate() []byte

+ func (m *EncodeAggDistinctPB) Marshal() (dAtA []byte, err error)

+ func (m *EncodeAggDistinctPB) MarshalTo(dAtA []byte) (int, error)

+ func (m *EncodeAggDistinctPB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EncodeAggDistinctPB) ProtoSize() (n int)

+ func (m *EncodeAggDistinctPB) Reset()

+ func (m *EncodeAggDistinctPB) String() string

+ func (m *EncodeAggDistinctPB) Unmarshal(dAtA []byte) error

+ func (m *EncodeAggDistinctPB) XXX_DiscardUnknown()

+ func (m *EncodeAggDistinctPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EncodeAggDistinctPB) XXX_Merge(src proto.Message)

+ func (m *EncodeAggDistinctPB) XXX_Size() int

+ func (m *EncodeAggDistinctPB) XXX_Unmarshal(b []byte) error

type EncodeDecimalV

+ func (*EncodeDecimalV) Descriptor() ([]byte, []int)

+ func (*EncodeDecimalV) ProtoMessage()

+ func (m *EncodeDecimalV) GetCounts() []int64

+ func (m *EncodeDecimalV) Marshal() (dAtA []byte, err error)

+ func (m *EncodeDecimalV) MarshalTo(dAtA []byte) (int, error)

+ func (m *EncodeDecimalV) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EncodeDecimalV) ProtoSize() (n int)

+ func (m *EncodeDecimalV) Reset()

+ func (m *EncodeDecimalV) String() string

+ func (m *EncodeDecimalV) Unmarshal(dAtA []byte) error

+ func (m *EncodeDecimalV) XXX_DiscardUnknown()

+ func (m *EncodeDecimalV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EncodeDecimalV) XXX_Merge(src proto.Message)

+ func (m *EncodeDecimalV) XXX_Size() int

+ func (m *EncodeDecimalV) XXX_Unmarshal(b []byte) error

type EncodeVariance

+ func (*EncodeVariance) Descriptor() ([]byte, []int)

+ func (*EncodeVariance) ProtoMessage()

+ func (m *EncodeVariance) GetCounts() []float64

+ func (m *EncodeVariance) GetSum() []float64

+ func (m *EncodeVariance) Marshal() (dAtA []byte, err error)

+ func (m *EncodeVariance) MarshalTo(dAtA []byte) (int, error)

+ func (m *EncodeVariance) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EncodeVariance) ProtoSize() (n int)

+ func (m *EncodeVariance) Reset()

+ func (m *EncodeVariance) String() string

+ func (m *EncodeVariance) Unmarshal(dAtA []byte) error

+ func (m *EncodeVariance) XXX_DiscardUnknown()

+ func (m *EncodeVariance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EncodeVariance) XXX_Merge(src proto.Message)

+ func (m *EncodeVariance) XXX_Size() int

+ func (m *EncodeVariance) XXX_Unmarshal(b []byte) error

+ type Rank struct

+ Ps [][]int64

+ func NewRank() *Rank

+ func (r *Rank) BatchFill(rs, vs any, start, count int64, vps []uint64, zs []int64, nsp *nulls.Nulls) error

+ func (r *Rank) Eval(vs []int64, err error) ([]int64, error)

+ func (r *Rank) Fill(i int64, value int64, ov int64, z int64, isEmpty bool, isNull bool) (int64, bool, error)

+ func (r *Rank) Grows(_ int)

+ func (r *Rank) MarshalBinary() ([]byte, error)

+ func (r *Rank) Merge(xIndex int64, yIndex int64, x int64, y int64, xEmpty bool, yEmpty bool, ...) (int64, bool, error)

+ func (r *Rank) UnmarshalBinary(data []byte) error

+ type RowNumber struct

+ Ps [][]int64

+ func NewRowNumber() *RowNumber

+ func (r *RowNumber) BatchFill(rs, vs any, start, count int64, vps []uint64, zs []int64, nsp *nulls.Nulls) error

+ func (r *RowNumber) Eval(vs []int64, err error) ([]int64, error)

+ func (r *RowNumber) Fill(i int64, value int64, ov int64, z int64, isEmpty bool, isNull bool) (int64, bool, error)

+ func (r *RowNumber) Grows(_ int)

+ func (r *RowNumber) MarshalBinary() ([]byte, error)

+ func (r *RowNumber) Merge(xIndex int64, yIndex int64, x int64, y int64, xEmpty bool, yEmpty bool, ...) (int64, bool, error)

+ func (r *RowNumber) UnmarshalBinary(data []byte) error

type StdD128

+ Typ types.Type

type StdD64

+ Typ types.Type

+ type StrAnyvalue struct

+ NotSet []bool

+ func NewStrAnyValue() *StrAnyvalue

+ func (a *StrAnyvalue) Eval(vs [][]byte, err error) ([][]byte, error)

+ func (a *StrAnyvalue) Fill(i int64, value []byte, ov []byte, z int64, isEmpty bool, isNull bool) ([]byte, bool, error)

+ func (a *StrAnyvalue) Grows(size int)

+ func (a *StrAnyvalue) MarshalBinary() ([]byte, error)

+ func (a *StrAnyvalue) Merge(xIndex int64, yIndex int64, x []byte, y []byte, xEmpty bool, yEmpty bool, ...) ([]byte, bool, error)

+ func (a *StrAnyvalue) UnmarshalBinary(data []byte) error

type VD128

+ ScaleDiv int32

+ ScaleDivMul int32

+ ScaleMul int32

+ ScaleMulDiv int32

+ Typ types.Type

+ func (*VD128) Descriptor() ([]byte, []int)

+ func (*VD128) ProtoMessage()

+ func (m *VD128) GetCounts() []int64

+ func (m *VD128) GetScaleDiv() int32

+ func (m *VD128) GetScaleDivMul() int32

+ func (m *VD128) GetScaleMul() int32

+ func (m *VD128) GetScaleMulDiv() int32

+ func (m *VD128) Marshal() (dAtA []byte, err error)

+ func (m *VD128) MarshalTo(dAtA []byte) (int, error)

+ func (m *VD128) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VD128) ProtoSize() (n int)

+ func (m *VD128) Reset()

+ func (m *VD128) String() string

+ func (m *VD128) Unmarshal(dAtA []byte) error

+ func (m *VD128) XXX_DiscardUnknown()

+ func (m *VD128) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VD128) XXX_Merge(src proto.Message)

+ func (m *VD128) XXX_Size() int

+ func (m *VD128) XXX_Unmarshal(b []byte) error

type VD64

+ ScaleDiv int32

+ ScaleDivMul int32

+ ScaleMul int32

+ ScaleMulDiv int32

+ Typ types.Type

+ func (*VD64) Descriptor() ([]byte, []int)

+ func (*VD64) ProtoMessage()

+ func (m *VD64) GetCounts() []int64

+ func (m *VD64) GetScaleDiv() int32

+ func (m *VD64) GetScaleDivMul() int32

+ func (m *VD64) GetScaleMul() int32

+ func (m *VD64) GetScaleMulDiv() int32

+ func (m *VD64) Marshal() (dAtA []byte, err error)

+ func (m *VD64) MarshalTo(dAtA []byte) (int, error)

+ func (m *VD64) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VD64) ProtoSize() (n int)

+ func (m *VD64) Reset()

+ func (m *VD64) String() string

+ func (m *VD64) Unmarshal(dAtA []byte) error

+ func (m *VD64) XXX_DiscardUnknown()

+ func (m *VD64) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VD64) XXX_Merge(src proto.Message)

+ func (m *VD64) XXX_Size() int

+ func (m *VD64) XXX_Unmarshal(b []byte) error

+ type VariancePB struct

+ Counts []float64

+ Sum []float64

+ func (*VariancePB) Descriptor() ([]byte, []int)

+ func (*VariancePB) ProtoMessage()

+ func (m *VariancePB) GetCounts() []float64

+ func (m *VariancePB) GetSum() []float64

+ func (m *VariancePB) Marshal() (dAtA []byte, err error)

+ func (m *VariancePB) MarshalTo(dAtA []byte) (int, error)

+ func (m *VariancePB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VariancePB) ProtoSize() (n int)

+ func (m *VariancePB) Reset()

+ func (m *VariancePB) String() string

+ func (m *VariancePB) Unmarshal(dAtA []byte) error

+ func (m *VariancePB) XXX_DiscardUnknown()

+ func (m *VariancePB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VariancePB) XXX_Merge(src proto.Message)

+ func (m *VariancePB) XXX_Size() int

+ func (m *VariancePB) XXX_Unmarshal(b []byte) error

v0.7.0

Feb 18, 2023

Changes in this version

+ const AggregateGroupConcat

+ const AggregateMedian

+ func MedianReturnType(typs []types.Type) types.Type

+ type Decimal128Median struct

+ Vals []decimal128Slice

+ func NewD128Median() *Decimal128Median

+ func (m *Decimal128Median) Eval(vs []types.Decimal128) []types.Decimal128

+ func (m *Decimal128Median) Fill(i int64, value types.Decimal128, _ types.Decimal128, z int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (m *Decimal128Median) Grows(cnt int)

+ func (m *Decimal128Median) MarshalBinary() ([]byte, error)

+ func (m *Decimal128Median) Merge(xIndex int64, yIndex int64, _ types.Decimal128, _ types.Decimal128, ...) (types.Decimal128, bool)

+ func (m *Decimal128Median) UnmarshalBinary(dt []byte) error

+ type Decimal64Median struct

+ Vals []decimal64Slice

+ func NewD64Median() *Decimal64Median

+ func (m *Decimal64Median) Eval(vs []types.Decimal128) []types.Decimal128

+ func (m *Decimal64Median) Fill(i int64, value types.Decimal64, ov types.Decimal128, z int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (m *Decimal64Median) Grows(cnt int)

+ func (m *Decimal64Median) MarshalBinary() ([]byte, error)

+ func (m *Decimal64Median) Merge(xIndex int64, yIndex int64, _ types.Decimal128, _ types.Decimal128, ...) (types.Decimal128, bool)

+ func (m *Decimal64Median) UnmarshalBinary(dt []byte) error

+ type Median struct

+ Vals []numericSlice[T]

+ func NewMedian() *Median[T]

+ func (m *Median[T]) Eval(vs []float64) []float64

+ func (m *Median[T]) Fill(i int64, value T, _ float64, z int64, isEmpty bool, isNull bool) (float64, bool)

+ func (m *Median[T]) Grows(cnt int)

+ func (m *Median[T]) MarshalBinary() ([]byte, error)

+ func (m *Median[T]) Merge(xIndex int64, yIndex int64, _ float64, _ float64, xEmpty bool, yEmpty bool, ...) (float64, bool)

+ func (m *Median[T]) UnmarshalBinary(data []byte) error

v0.6.0

Nov 29, 2022

Changes in this version

+ const AggregateAnyValue

+ const AggregateApproxCountDistinct

+ const AggregateAvg

+ const AggregateBitAnd

+ const AggregateBitOr

+ const AggregateBitXor

+ const AggregateCount

+ const AggregateMax

+ const AggregateMin

+ const AggregateStarCount

+ const AggregateStdDevPop

+ const AggregateSum

+ const AggregateVariance

+ var Names = [...]string

+ func AnyValueReturnType(typs []types.Type) types.Type

+ func ApproxCountReturnType(_ []types.Type) types.Type

+ func AvgReturnType(typs []types.Type) types.Type

+ func BitAndReturnType(typs []types.Type) types.Type

+ func BitOrReturnType(_ []types.Type) types.Type

+ func BitXorReturnType(_ []types.Type) types.Type

+ func CountReturnType(_ []types.Type) types.Type

+ func MaxReturnType(typs []types.Type) types.Type

+ func MinReturnType(typs []types.Type) types.Type

+ func ReturnType(op int, typ types.Type) (types.Type, error)

+ func StdDevPopReturnType(typs []types.Type) types.Type

+ func String(b []byte) (s string)

+ func SumReturnType(typs []types.Type) types.Type

+ func VarianceReturnType(typs []types.Type) types.Type

type Agg

+ func New(op int, dist bool, typ types.Type) (Agg[any], error)

+ GetInputTypes func() []types.Type

+ GetOperatorId func() int

+ IsDistinct func() bool

+ UnmarshalBinary func(data []byte, m *mpool.MPool) error

+ WildAggReAlloc func(m *mpool.MPool) error

+ type AggStruct interface

+ type Aggregate struct

+ Dist bool

+ E *plan.Expr

+ Op int

+ type Anyvalue struct

+ NotSet []bool

+ func NewAnyValue() *Anyvalue[T]

+ func (a *Anyvalue[T]) Eval(vs []T) []T

+ func (a *Anyvalue[T]) Fill(i int64, value T, ov T, z int64, isEmpty bool, isNull bool) (T, bool)

+ func (a *Anyvalue[T]) Grows(size int)

+ func (a *Anyvalue[T]) MarshalBinary() ([]byte, error)

+ func (a *Anyvalue[T]) Merge(xIndex int64, yIndex int64, x T, y T, xEmpty bool, yEmpty bool, yAnyValue any) (T, bool)

+ func (a *Anyvalue[T]) UnmarshalBinary(data []byte) error

+ type ApproxCountDistic struct

+ Sk []*hll.Sketch

+ func NewApproxc() *ApproxCountDistic[T]

+ func (a *ApproxCountDistic[T]) Eval(vs []uint64) []uint64

+ func (a *ApproxCountDistic[T]) Fill(n int64, v1 T, v2 uint64, _ int64, isEmpty bool, isNull bool) (uint64, bool)

+ func (a *ApproxCountDistic[T]) Grows(n int)

+ func (a *ApproxCountDistic[T]) MarshalBinary() ([]byte, error)

+ func (a *ApproxCountDistic[T]) Merge(xIndex int64, yIndex int64, x uint64, _ uint64, xEmpty bool, yEmpty bool, ...) (uint64, bool)

+ func (a *ApproxCountDistic[T]) UnmarshalBinary(data []byte) error

+ type Avg struct

+ Cnts []int64

+ func NewAvg() *Avg[T]

+ func (a *Avg[T]) Eval(vs []float64) []float64

+ func (a *Avg[T]) Fill(i int64, value T, ov float64, z int64, isEmpty bool, isNull bool) (float64, bool)

+ func (a *Avg[T]) Grows(cnt int)

+ func (a *Avg[T]) MarshalBinary() ([]byte, error)

+ func (a *Avg[T]) Merge(xIndex int64, yIndex int64, x float64, y float64, xEmpty bool, yEmpty bool, ...) (float64, bool)

+ func (a *Avg[T]) UnmarshalBinary(data []byte) error

+ type BitAnd struct

+ func NewBitAnd() *BitAnd[T1]

+ func (ba *BitAnd[T1]) Eval(vs []uint64) []uint64

+ func (ba *BitAnd[T1]) Fill(groupIndex int64, v1 T1, v2 uint64, z int64, isEmpty bool, hasNull bool) (uint64, bool)

+ func (ba *BitAnd[T1]) Grows(_ int)

+ func (ba *BitAnd[T1]) MarshalBinary() ([]byte, error)

+ func (ba *BitAnd[T1]) Merge(groupIndex1, groupIndex2 int64, x, y uint64, isEmpty1 bool, isEmpty2 bool, ...) (uint64, bool)

+ func (ba *BitAnd[T1]) UnmarshalBinary(data []byte) error

+ type BitOr struct

+ func NewBitOr() *BitOr[T1]

+ func (bo *BitOr[T1]) Eval(vs []uint64) []uint64

+ func (bo *BitOr[T1]) Fill(_ int64, v1 T1, v2 uint64, _ int64, IsEmpty bool, hasNull bool) (uint64, bool)

+ func (bo *BitOr[T1]) Grows(_ int)

+ func (bo *BitOr[T1]) MarshalBinary() ([]byte, error)

+ func (bo *BitOr[T1]) Merge(_, _ int64, x, y uint64, IsEmpty1 bool, IsEmpty2 bool, _ any) (uint64, bool)

+ func (bo *BitOr[T1]) UnmarshalBinary(data []byte) error

+ type BitXor struct

+ func NewBitXor() *BitXor[T1]

+ func (bx *BitXor[T1]) Eval(vs []uint64) []uint64

+ func (bx *BitXor[T1]) Fill(_ int64, v1 T1, v2 uint64, z int64, IsEmpty bool, hasNull bool) (uint64, bool)

+ func (bx *BitXor[T1]) Grows(_ int)

+ func (bx *BitXor[T1]) MarshalBinary() ([]byte, error)

+ func (bx *BitXor[T1]) Merge(_, _ int64, x, y uint64, IsEmpty1 bool, IsEmpty2 bool, _ any) (uint64, bool)

+ func (bx *BitXor[T1]) UnmarshalBinary(data []byte) error

+ type BoolMax struct

+ func NewBoolMax() *BoolMax

+ func (m *BoolMax) Eval(vs []bool) []bool

+ func (m *BoolMax) Fill(_ int64, value bool, ov bool, _ int64, isEmpty bool, isNull bool) (bool, bool)

+ func (m *BoolMax) Grows(_ int)

+ func (m *BoolMax) MarshalBinary() ([]byte, error)

+ func (m *BoolMax) Merge(_ int64, _ int64, x bool, y bool, xEmpty bool, yEmpty bool, _ any) (bool, bool)

+ func (m *BoolMax) UnmarshalBinary(data []byte) error

+ type BoolMin struct

+ func NewBoolMin() *BoolMin

+ func (m *BoolMin) Eval(vs []bool) []bool

+ func (m *BoolMin) Fill(_ int64, value bool, ov bool, _ int64, isEmpty bool, isNull bool) (bool, bool)

+ func (m *BoolMin) Grows(_ int)

+ func (m *BoolMin) MarshalBinary() ([]byte, error)

+ func (m *BoolMin) Merge(_ int64, _ int64, x bool, y bool, xEmpty bool, yEmpty bool, _ any) (bool, bool)

+ func (m *BoolMin) UnmarshalBinary(data []byte) error

+ type Compare interface

+ type Count struct

+ IsStar bool

+ func NewCount(isStar bool) *Count[T1]

+ func (c *Count[T1]) Eval(vs []int64) []int64

+ func (c *Count[T1]) Fill(_ int64, _ T1, v int64, z int64, _ bool, hasNull bool) (int64, bool)

+ func (c *Count[T1]) Grows(_ int)

+ func (c *Count[T1]) MarshalBinary() ([]byte, error)

+ func (c *Count[T1]) Merge(_, _ int64, x, y int64, _ bool, _ bool, _ any) (int64, bool)

+ func (c *Count[T1]) UnmarshalBinary(data []byte) error

+ type Decimal128AndString interface

+ type Decimal128Avg struct

+ Cnts []int64

+ func NewD128Avg() *Decimal128Avg

+ func (a *Decimal128Avg) BatchFill(rs, vs any, start, count int64, vps []uint64, zs []int64, nsp *nulls.Nulls) error

+ func (a *Decimal128Avg) Eval(vs []types.Decimal128) []types.Decimal128

+ func (a *Decimal128Avg) Fill(i int64, value types.Decimal128, ov types.Decimal128, z int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (a *Decimal128Avg) Grows(cnt int)

+ func (a *Decimal128Avg) MarshalBinary() ([]byte, error)

+ func (a *Decimal128Avg) Merge(xIndex int64, yIndex int64, x types.Decimal128, y types.Decimal128, ...) (types.Decimal128, bool)

+ func (a *Decimal128Avg) UnmarshalBinary(data []byte) error

+ type Decimal128Max struct

+ func NewD128Max() *Decimal128Max

+ func (m *Decimal128Max) Eval(vs []types.Decimal128) []types.Decimal128

+ func (m *Decimal128Max) Fill(_ int64, value types.Decimal128, ov types.Decimal128, _ int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (m *Decimal128Max) Grows(_ int)

+ func (m *Decimal128Max) MarshalBinary() ([]byte, error)

+ func (m *Decimal128Max) Merge(_ int64, _ int64, x types.Decimal128, y types.Decimal128, xEmpty bool, ...) (types.Decimal128, bool)

+ func (m *Decimal128Max) UnmarshalBinary(data []byte) error

+ type Decimal128Min struct

+ func NewD128Min() *Decimal128Min

+ func (m *Decimal128Min) Eval(vs []types.Decimal128) []types.Decimal128

+ func (m *Decimal128Min) Fill(_ int64, value types.Decimal128, ov types.Decimal128, _ int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (m *Decimal128Min) Grows(_ int)

+ func (m *Decimal128Min) MarshalBinary() ([]byte, error)

+ func (m *Decimal128Min) Merge(_ int64, _ int64, x types.Decimal128, y types.Decimal128, xEmpty bool, ...) (types.Decimal128, bool)

+ func (m *Decimal128Min) UnmarshalBinary(data []byte) error

+ type Decimal128Sum struct

+ func NewD128Sum() *Decimal128Sum

+ func (s *Decimal128Sum) BatchFill(rs, vs any, start, count int64, vps []uint64, zs []int64, nsp *nulls.Nulls) error

+ func (s *Decimal128Sum) Eval(vs []types.Decimal128) []types.Decimal128

+ func (s *Decimal128Sum) Fill(_ int64, value types.Decimal128, ov types.Decimal128, z int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (s *Decimal128Sum) Grows(_ int)

+ func (s *Decimal128Sum) MarshalBinary() ([]byte, error)

+ func (s *Decimal128Sum) Merge(_ int64, _ int64, x types.Decimal128, y types.Decimal128, xEmpty bool, ...) (types.Decimal128, bool)

+ func (s *Decimal128Sum) UnmarshalBinary(data []byte) error

+ type Decimal64Avg struct

+ Cnts []int64

+ func NewD64Avg() *Decimal64Avg

+ func (a *Decimal64Avg) BatchFill(rs, vs any, start, count int64, vps []uint64, zs []int64, nsp *nulls.Nulls) error

+ func (a *Decimal64Avg) Eval(vs []types.Decimal128) []types.Decimal128

+ func (a *Decimal64Avg) Fill(i int64, value types.Decimal64, ov types.Decimal128, z int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (a *Decimal64Avg) Grows(cnt int)

+ func (a *Decimal64Avg) MarshalBinary() ([]byte, error)

+ func (a *Decimal64Avg) Merge(xIndex int64, yIndex int64, x types.Decimal128, y types.Decimal128, ...) (types.Decimal128, bool)

+ func (a *Decimal64Avg) UnmarshalBinary(data []byte) error

+ type Decimal64Max struct

+ func NewD64Max() *Decimal64Max

+ func (m *Decimal64Max) Eval(vs []types.Decimal64) []types.Decimal64

+ func (m *Decimal64Max) Fill(_ int64, value types.Decimal64, ov types.Decimal64, _ int64, isEmpty bool, ...) (types.Decimal64, bool)

+ func (m *Decimal64Max) Grows(_ int)

+ func (m *Decimal64Max) MarshalBinary() ([]byte, error)

+ func (m *Decimal64Max) Merge(_ int64, _ int64, x types.Decimal64, y types.Decimal64, xEmpty bool, ...) (types.Decimal64, bool)

+ func (m *Decimal64Max) UnmarshalBinary(data []byte) error

+ type Decimal64Min struct

+ func NewD64Min() *Decimal64Min

+ func (m *Decimal64Min) Eval(vs []types.Decimal64) []types.Decimal64

+ func (m *Decimal64Min) Fill(_ int64, value types.Decimal64, ov types.Decimal64, _ int64, isEmpty bool, ...) (types.Decimal64, bool)

+ func (m *Decimal64Min) Grows(_ int)

+ func (m *Decimal64Min) MarshalBinary() ([]byte, error)

+ func (m *Decimal64Min) Merge(_ int64, _ int64, x types.Decimal64, y types.Decimal64, xEmpty bool, ...) (types.Decimal64, bool)

+ func (m *Decimal64Min) UnmarshalBinary(data []byte) error

+ type Decimal64Sum struct

+ func NewD64Sum() *Decimal64Sum

+ func (s *Decimal64Sum) BatchFill(rs, vs any, start, count int64, vps []uint64, zs []int64, nsp *nulls.Nulls) error

+ func (s *Decimal64Sum) Eval(vs []types.Decimal64) []types.Decimal64

+ func (s *Decimal64Sum) Fill(_ int64, value types.Decimal64, ov types.Decimal64, z int64, isEmpty bool, ...) (types.Decimal64, bool)

+ func (s *Decimal64Sum) Grows(_ int)

+ func (s *Decimal64Sum) MarshalBinary() ([]byte, error)

+ func (s *Decimal64Sum) Merge(_ int64, _ int64, x types.Decimal64, y types.Decimal64, xEmpty bool, ...) (types.Decimal64, bool)

+ func (s *Decimal64Sum) UnmarshalBinary(data []byte) error

+ type EncodeAgg struct

+ Da []byte

+ Es []bool

+ InputTypes []byte

+ IsCount bool

+ Op int

+ OutputType []byte

+ Private []byte

+ type EncodeAggDistinct struct

+ Da []byte

+ Es []bool

+ InputType []types.Type

+ IsCount bool

+ Op int

+ OutputType types.Type

+ Private []byte

+ Srcs [][]T

+ type EncodeDecimalV struct

+ Counts []int64

+ Sum []types.Decimal128

+ type EncodeVariance struct

+ Counts []float64

+ Sum []float64

+ type Max struct

+ func NewMax() *Max[T]

+ func (m *Max[T]) Eval(vs []T) []T

+ func (m *Max[T]) Fill(_ int64, value T, ov T, _ int64, isEmpty bool, isNull bool) (T, bool)

+ func (m *Max[T]) Grows(_ int)

+ func (m *Max[T]) MarshalBinary() ([]byte, error)

+ func (m *Max[T]) Merge(_ int64, _ int64, x T, y T, xEmpty bool, yEmpty bool, _ any) (T, bool)

+ func (m *Max[T]) UnmarshalBinary(data []byte) error

+ type Min struct

+ func NewMin() *Min[T]

+ func (m *Min[T]) Eval(vs []T) []T

+ func (m *Min[T]) Fill(_ int64, value T, ov T, _ int64, isEmpty bool, isNull bool) (T, bool)

+ func (m *Min[T]) Grows(_ int)

+ func (m *Min[T]) MarshalBinary() ([]byte, error)

+ func (m *Min[T]) Merge(_ int64, _ int64, x T, y T, xEmpty bool, yEmpty bool, _ any) (T, bool)

+ func (m *Min[T]) UnmarshalBinary(data []byte) error

+ type Numeric interface

+ type ReturnTyp interface

+ type StdD128 struct

+ Variance *VD128

+ func NewStdD128() *StdD128

+ func (s *StdD128) Eval(vs []types.Decimal128) []types.Decimal128

+ func (s *StdD128) Fill(groupIndex int64, v1 types.Decimal128, v2 types.Decimal128, z int64, ...) (types.Decimal128, bool)

+ func (s *StdD128) Grows(size int)

+ func (s *StdD128) MarshalBinary() ([]byte, error)

+ func (s *StdD128) Merge(groupIndex1, groupIndex2 int64, x, y types.Decimal128, IsEmpty1 bool, ...) (types.Decimal128, bool)

+ func (s *StdD128) UnmarshalBinary(data []byte) error

+ type StdD64 struct

+ Variance *VD64

+ func NewStdD64() *StdD64

+ func (s *StdD64) Eval(vs []types.Decimal128) []types.Decimal128

+ func (s *StdD64) Fill(groupIndex int64, v1 types.Decimal64, v2 types.Decimal128, z int64, ...) (types.Decimal128, bool)

+ func (s *StdD64) Grows(size int)

+ func (s *StdD64) MarshalBinary() ([]byte, error)

+ func (s *StdD64) Merge(groupIndex1, groupIndex2 int64, x, y types.Decimal128, IsEmpty1 bool, ...) (types.Decimal128, bool)

+ func (s *StdD64) UnmarshalBinary(data []byte) error

+ type Stddevpop struct

+ Variance *Variance[T1]

+ func NewStdDevPop() *Stddevpop[T1]

+ func (sdp *Stddevpop[T1]) Eval(vs []float64) []float64

+ func (sdp *Stddevpop[T1]) Fill(groupIndex int64, v1 T1, v2 float64, z int64, IsEmpty bool, hasNull bool) (float64, bool)

+ func (sdp *Stddevpop[T1]) Grows(sizes int)

+ func (sdp *Stddevpop[T1]) MarshalBinary() ([]byte, error)

+ func (sdp *Stddevpop[T1]) Merge(groupIndex1, groupIndex2 int64, x, y float64, IsEmpty1 bool, IsEmpty2 bool, ...) (float64, bool)

+ func (sdp *Stddevpop[T1]) UnmarshalBinary(data []byte) error

+ type StrMax struct

+ func NewStrMax() *StrMax

+ func (m *StrMax) Eval(vs [][]byte) [][]byte

+ func (m *StrMax) Fill(_ int64, value []byte, ov []byte, _ int64, isEmpty bool, isNull bool) ([]byte, bool)

+ func (m *StrMax) Grows(_ int)

+ func (m *StrMax) MarshalBinary() ([]byte, error)

+ func (m *StrMax) Merge(_ int64, _ int64, x []byte, y []byte, xEmpty bool, yEmpty bool, _ any) ([]byte, bool)

+ func (m *StrMax) UnmarshalBinary(data []byte) error

+ type StrMin struct

+ func NewStrMin() *StrMin

+ func (m *StrMin) Eval(vs [][]byte) [][]byte

+ func (m *StrMin) Fill(_ int64, value []byte, ov []byte, _ int64, isEmpty bool, isNull bool) ([]byte, bool)

+ func (m *StrMin) Grows(_ int)

+ func (m *StrMin) MarshalBinary() ([]byte, error)

+ func (m *StrMin) Merge(_ int64, _ int64, x []byte, y []byte, xEmpty bool, yEmpty bool, _ any) ([]byte, bool)

+ func (m *StrMin) UnmarshalBinary(data []byte) error

+ type Sum struct

+ func NewSum() *Sum[T1, T2]

+ func (s *Sum[T1, T2]) Eval(vs []T2) []T2

+ func (s *Sum[T1, T2]) Fill(_ int64, value T1, ov T2, z int64, isEmpty bool, isNull bool) (T2, bool)

+ func (s *Sum[T1, T2]) Grows(_ int)

+ func (s *Sum[T1, T2]) MarshalBinary() ([]byte, error)

+ func (s *Sum[T1, T2]) Merge(_ int64, _ int64, x T2, y T2, xEmpty bool, yEmpty bool, _ any) (T2, bool)

+ func (s *Sum[T1, T2]) UnmarshalBinary(data []byte) error

type UnaryAgg

+ func (a *UnaryAgg[T1, T2]) GetInputTypes() []types.Type

+ func (a *UnaryAgg[T1, T2]) GetOperatorId() int

+ func (a *UnaryAgg[T1, T2]) IsDistinct() bool

+ func (a *UnaryAgg[T1, T2]) MarshalBinary() ([]byte, error)

+ func (a *UnaryAgg[T1, T2]) UnmarshalBinary(data []byte, mp *mpool.MPool) error

+ func (a *UnaryAgg[T1, T2]) WildAggReAlloc(m *mpool.MPool) error

type UnaryDistAgg

+ func (a *UnaryDistAgg[T1, T2]) GetInputTypes() []types.Type

+ func (a *UnaryDistAgg[T1, T2]) GetOperatorId() int

+ func (a *UnaryDistAgg[T1, T2]) IsDistinct() bool

+ func (a *UnaryDistAgg[T1, T2]) MarshalBinary() ([]byte, error)

+ func (a *UnaryDistAgg[T1, T2]) UnmarshalBinary(data []byte, m *mpool.MPool) error

+ func (a *UnaryDistAgg[T1, T2]) WildAggReAlloc(m *mpool.MPool) error

+ type UuidMax struct

+ func NewUuidMax() *UuidMax

+ func (m *UuidMax) Eval(vs []types.Uuid) []types.Uuid

+ func (m *UuidMax) Fill(_ int64, value types.Uuid, ov types.Uuid, _ int64, isEmpty bool, isNull bool) (types.Uuid, bool)

+ func (m *UuidMax) Grows(_ int)

+ func (m *UuidMax) MarshalBinary() ([]byte, error)

+ func (m *UuidMax) Merge(_ int64, _ int64, x types.Uuid, y types.Uuid, xEmpty bool, yEmpty bool, _ any) (types.Uuid, bool)

+ func (m *UuidMax) UnmarshalBinary(data []byte) error

+ type UuidMin struct

+ func NewUuidMin() *UuidMin

+ func (m *UuidMin) Eval(vs []types.Uuid) []types.Uuid

+ func (m *UuidMin) Fill(_ int64, value types.Uuid, ov types.Uuid, _ int64, isEmpty bool, isNull bool) (types.Uuid, bool)

+ func (m *UuidMin) Grows(_ int)

+ func (m *UuidMin) MarshalBinary() ([]byte, error)

+ func (m *UuidMin) Merge(_ int64, _ int64, x types.Uuid, y types.Uuid, xEmpty bool, yEmpty bool, _ any) (types.Uuid, bool)

+ func (m *UuidMin) UnmarshalBinary(data []byte) error

+ type VD128 struct

+ Counts []int64

+ Sum []types.Decimal128

+ func NewVD128() *VD128

+ func (v *VD128) Eval(vs []types.Decimal128) []types.Decimal128

+ func (v *VD128) Fill(i int64, v1 types.Decimal128, v2 types.Decimal128, z int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (v *VD128) Grows(cnt int)

+ func (v *VD128) MarshalBinary() ([]byte, error)

+ func (v *VD128) Merge(xIndex, yIndex int64, x types.Decimal128, y types.Decimal128, xEmpty bool, ...) (types.Decimal128, bool)

+ func (v *VD128) UnmarshalBinary(data []byte) error

+ type VD64 struct

+ Counts []int64

+ Sum []types.Decimal128

+ func NewVD64() *VD64

+ func (v *VD64) Eval(vs []types.Decimal128) []types.Decimal128

+ func (v *VD64) Fill(i int64, v1 types.Decimal64, v2 types.Decimal128, z int64, isEmpty bool, ...) (types.Decimal128, bool)

+ func (v *VD64) Grows(cnt int)

+ func (v *VD64) MarshalBinary() ([]byte, error)

+ func (v *VD64) Merge(xIndex, yIndex int64, x types.Decimal128, y types.Decimal128, xEmpty bool, ...) (types.Decimal128, bool)

+ func (v *VD64) UnmarshalBinary(data []byte) error

+ type Variance struct

+ Counts []float64

+ Sum []float64

+ func NewVariance() *Variance[T1]

+ func (variance *Variance[T1]) Eval(vs []float64) []float64

+ func (variance *Variance[T1]) Fill(groupIndex int64, v1 T1, v2 float64, z int64, IsEmpty bool, hasNull bool) (float64, bool)

+ func (variance *Variance[T1]) Grows(count int)

+ func (variance *Variance[T1]) MarshalBinary() ([]byte, error)

+ func (variance *Variance[T1]) Merge(groupIndex1, groupIndex2 int64, x, y float64, IsEmpty1 bool, IsEmpty2 bool, ...) (float64, bool)

+ func (variance *Variance[T1]) UnmarshalBinary(data []byte) error

v0.5.1

Aug 17, 2022

Changes in this version

+ type Agg interface

+ BatchFill func(offset int64, os []uint8, vps []uint64, rowCounts []int64, ...)

+ BatchMerge func(agg2 Agg[any], start int64, os []uint8, vps []uint64)

+ BulkFill func(groupIndex int64, rowCounts []int64, vecs []*vector.Vector)

+ Dup func() Agg[any]

+ Eval func(_ *mheap.Mheap) (*vector.Vector, error)

+ Fill func(groupIndex int64, rowIndex int64, rowCount int64, vecs []*vector.Vector)

+ Free func(*mheap.Mheap)

+ Grows func(n int, _ *mheap.Mheap) error

+ InputTypes func() []types.Type

+ Merge func(agg2 Agg[any], groupIndex1 int64, groupIndex2 int64)

+ OutputType func() types.Type

+ String func() string

+ func NewUnaryAgg(isCount bool, ityp, otyp types.Type, grows func(int), eval func([]T2) []T2, ...) Agg[*UnaryAgg[T1, T2]]

+ func NewUnaryDistAgg(isCount bool, ityp, otyp types.Type, grows func(int), eval func([]T2) []T2, ...) Agg[*UnaryDistAgg[T1, T2]]

+ type UnaryAgg struct

+ func (a *UnaryAgg[T1, T2]) BatchFill(start int64, os []uint8, vps []uint64, zs []int64, vecs []*vector.Vector)

+ func (a *UnaryAgg[T1, T2]) BatchMerge(b Agg[any], start int64, os []uint8, vps []uint64)

+ func (a *UnaryAgg[T1, T2]) BulkFill(i int64, zs []int64, vecs []*vector.Vector)

+ func (a *UnaryAgg[T1, T2]) Dup() Agg[any]

+ func (a *UnaryAgg[T1, T2]) Eval(m *mheap.Mheap) (*vector.Vector, error)

+ func (a *UnaryAgg[T1, T2]) Fill(i int64, sel, z int64, vecs []*vector.Vector)

+ func (a *UnaryAgg[T1, T2]) Free(m *mheap.Mheap)

+ func (a *UnaryAgg[T1, T2]) Grows(size int, m *mheap.Mheap) error

+ func (a *UnaryAgg[T1, T2]) InputTypes() []types.Type

+ func (a *UnaryAgg[T1, T2]) Merge(b Agg[any], x, y int64)

+ func (a *UnaryAgg[T1, T2]) OutputType() types.Type

+ func (a *UnaryAgg[T1, T2]) String() string

+ type UnaryDistAgg struct

+ func (a *UnaryDistAgg[T1, T2]) BatchFill(start int64, os []uint8, vps []uint64, zs []int64, vecs []*vector.Vector)

+ func (a *UnaryDistAgg[T1, T2]) BatchMerge(b Agg[any], start int64, os []uint8, vps []uint64)

+ func (a *UnaryDistAgg[T1, T2]) BulkFill(i int64, zs []int64, vecs []*vector.Vector)

+ func (a *UnaryDistAgg[T1, T2]) Dup() Agg[any]

+ func (a *UnaryDistAgg[T1, T2]) Eval(m *mheap.Mheap) (*vector.Vector, error)

+ func (a *UnaryDistAgg[T1, T2]) Fill(i int64, sel, z int64, vecs []*vector.Vector)

+ func (a *UnaryDistAgg[T1, T2]) Free(m *mheap.Mheap)

+ func (a *UnaryDistAgg[T1, T2]) Grows(size int, m *mheap.Mheap) error

+ func (a *UnaryDistAgg[T1, T2]) InputTypes() []types.Type

+ func (a *UnaryDistAgg[T1, T2]) Merge(b Agg[any], x, y int64)

+ func (a *UnaryDistAgg[T1, T2]) OutputType() types.Type

+ func (a *UnaryDistAgg[T1, T2]) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL