agg

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 30, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AggregateSum = iota
	AggregateAvg
	AggregateMax
	AggregateMin
	AggregateCount
	AggregateStarCount
	AggregateApproxCountDistinct
	AggregateVariance
	AggregateBitAnd
	AggregateBitXor
	AggregateBitOr
	AggregateStdDevPop
	AggregateAnyValue
	AggregateMedian
	AggregateGroupConcat

	WinRank
	WinRowNumber
	WinDenseRank
)

Variables

View Source
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source
var Names = [...]string{
	AggregateSum:                 "sum",
	AggregateAvg:                 "avg",
	AggregateMax:                 "max",
	AggregateMin:                 "min",
	AggregateCount:               "count",
	AggregateStarCount:           "starcount",
	AggregateApproxCountDistinct: "approx_count_distinct",
	AggregateVariance:            "var",
	AggregateBitAnd:              "bit_and",
	AggregateBitXor:              "bit_xor",
	AggregateBitOr:               "bit_or",
	AggregateStdDevPop:           "stddev_pop",
	AggregateAnyValue:            "any",
	AggregateMedian:              "median",
	AggregateGroupConcat:         "group_concat",

	WinRank:      "rank",
	WinRowNumber: "row_number",
	WinDenseRank: "dense_rank",
}

Functions

func AnyValueReturnType added in v0.6.0

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

func ApproxCountReturnType added in v0.6.0

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

func AvgReturnType added in v0.6.0

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

func BitAndReturnType added in v0.6.0

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

func BitOrReturnType added in v0.6.0

func BitOrReturnType(typs []types.Type) types.Type

func BitXorReturnType added in v0.6.0

func BitXorReturnType(typs []types.Type) types.Type

func CountReturnType added in v0.6.0

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

func DenseRankReturnType added in v0.8.0

func DenseRankReturnType() types.Type

func MaxReturnType added in v0.6.0

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

func MedianReturnType added in v0.7.0

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

func MinReturnType added in v0.6.0

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

func RankReturnType added in v0.8.0

func RankReturnType() types.Type

func ReturnType added in v0.6.0

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

ReturnType get aggregate operator's return type according to its operator-id and input-types.

func RowNumberReturnType added in v0.8.0

func RowNumberReturnType() types.Type

func StdDevPopReturnType added in v0.6.0

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

func SumReturnType added in v0.6.0

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

func VarianceReturnType added in v0.6.0

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

Types

type Agg

type Agg[T any] interface {
	encoding.BinaryMarshaler
	encoding.BinaryUnmarshaler

	// Dup will duplicate a new agg with the same type.
	Dup() Agg[any]

	// Type return the type of the agg's result.
	OutputType() types.Type

	// InputType return the type of the agg's input.
	InputTypes() []types.Type

	// String return related information of the agg.
	// used to show query plans.
	String() string

	// Free the agg.
	Free(*mpool.MPool)

	// Grows allocates n groups for the agg.
	Grows(n int, m *mpool.MPool) error

	// Eval method calculates and returns the final result of the aggregate function.
	Eval(_ *mpool.MPool) (*vector.Vector, error)

	// Fill use the rowIndex-rows of vector to update the data of groupIndex-group.
	// rowCount indicates the number of times the rowIndex-row is repeated.
	Fill(groupIndex int64, rowIndex int64, rowCount int64, vecs []*vector.Vector) error

	// BulkFill use a whole vector to update the data of agg's group
	// groupIndex is the index number of the group
	// rowCounts is the count number of each row.
	BulkFill(groupIndex int64, rowCounts []int64, vecs []*vector.Vector) error

	// BatchFill use part of the vector to update the data of agg's group
	//      os(origin-s) records information about which groups need to be updated
	//      if length of os is N, we use first N of vps to do update work.
	//      And if os[i] > 0, it means the agg's (vps[i]-1)th group is a new one (never been assigned a value),
	//      Maybe this feature can help us to do some optimization work.
	//      So we use the os as a parameter but not len(os).
	//
	//      agg's (vps[i]-1)th group is related to vector's (offset+i)th row.
	//      rowCounts[i] is count number of the row[i]
	// For a more detailed introduction of rowCounts, please refer to comments of Function Fill.
	BatchFill(offset int64, os []uint8, vps []uint64, rowCounts []int64, vecs []*vector.Vector) error

	// Merge will merge a couple of group between 2 aggregate function structures.
	// It merges the groupIndex1-group of agg1 and
	// groupIndex2-group of agg2
	Merge(agg2 Agg[any], groupIndex1 int64, groupIndex2 int64) error

	// BatchMerge merges multi groups of agg1 and agg2
	//  agg1's (vps[i]-1)th group is related to agg2's (start+i)th group
	// For more introduction of os, please refer to comments of Function BatchFill.
	BatchMerge(agg2 Agg[any], start int64, os []uint8, vps []uint64) error

	// GetInputTypes get types of aggregate's input arguments.
	GetInputTypes() []types.Type

	// GetOperatorId get types of aggregate's aggregate id.
	GetOperatorId() int

	IsDistinct() bool

	// WildAggReAlloc reallocate for agg structure from memory pool.
	WildAggReAlloc(m *mpool.MPool) error
}

Agg agg interface

func New added in v0.6.0

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

func NewUnaryAgg

func NewUnaryAgg[T1, T2 any](op int, priv AggStruct, isCount bool, ityp, otyp types.Type, grows func(int),
	eval func([]T2, error) ([]T2, error), merge func(int64, int64, T2, T2, bool, bool, any) (T2, bool, error),
	fill func(int64, T1, T2, int64, bool, bool) (T2, bool, error),
	batchFill func(any, any, int64, int64, []uint64, []int64, *nulls.Nulls) error) Agg[*UnaryAgg[T1, T2]]

func NewUnaryDistAgg

func NewUnaryDistAgg[T1, T2 any](op int, priv AggStruct, isCount bool, ityp, otyp types.Type, grows func(int),
	eval func([]T2, error) ([]T2, error), merge func(int64, int64, T2, T2, bool, bool, any) (T2, bool, error),
	fill func(int64, T1, T2, int64, bool, bool) (T2, bool, error)) Agg[*UnaryDistAgg[T1, T2]]

type AggStruct added in v0.6.0

type AggStruct interface {
	encoding.BinaryMarshaler
	encoding.BinaryUnmarshaler
}

type Aggregate added in v0.6.0

type Aggregate struct {
	Op   int
	Dist bool
	E    *plan.Expr
}

type Anyvalue added in v0.6.0

type Anyvalue[T any] struct {
	NotSet []bool
}

func NewAnyValue added in v0.6.0

func NewAnyValue[T any]() *Anyvalue[T]

func (*Anyvalue[T]) Eval added in v0.6.0

func (a *Anyvalue[T]) Eval(vs []T, err error) ([]T, error)

func (*Anyvalue[T]) Fill added in v0.6.0

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

func (*Anyvalue[T]) Grows added in v0.6.0

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

func (*Anyvalue[T]) MarshalBinary added in v0.6.0

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

func (*Anyvalue[T]) Merge added in v0.6.0

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

func (*Anyvalue[T]) UnmarshalBinary added in v0.6.0

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

type ApproxCountDistic added in v0.6.0

type ApproxCountDistic[T any] struct {
	Sk []*hll.Sketch
}

func NewApproxc added in v0.6.0

func NewApproxc[T any]() *ApproxCountDistic[T]

func (*ApproxCountDistic[T]) Eval added in v0.6.0

func (a *ApproxCountDistic[T]) Eval(vs []uint64, err error) ([]uint64, error)

func (*ApproxCountDistic[T]) Fill added in v0.6.0

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

func (*ApproxCountDistic[T]) Grows added in v0.6.0

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

func (*ApproxCountDistic[T]) MarshalBinary added in v0.6.0

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

func (*ApproxCountDistic[T]) Merge added in v0.6.0

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

func (*ApproxCountDistic[T]) UnmarshalBinary added in v0.6.0

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

type Avg added in v0.6.0

type Avg[T Numeric] struct {
	Cnts []int64
}

func NewAvg added in v0.6.0

func NewAvg[T Numeric]() *Avg[T]

func (*Avg[T]) Eval added in v0.6.0

func (a *Avg[T]) Eval(vs []float64, err error) ([]float64, error)

func (*Avg[T]) Fill added in v0.6.0

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

func (*Avg[T]) Grows added in v0.6.0

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

func (*Avg[T]) MarshalBinary added in v0.6.0

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

func (*Avg[T]) Merge added in v0.6.0

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

func (*Avg[T]) UnmarshalBinary added in v0.6.0

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

type BitAnd added in v0.6.0

type BitAnd[T1 types.Ints | types.UInts | types.Floats] struct {
}

func NewBitAnd added in v0.6.0

func NewBitAnd[T1 types.Ints | types.UInts | types.Floats]() *BitAnd[T1]

func (*BitAnd[T1]) Eval added in v0.6.0

func (ba *BitAnd[T1]) Eval(vs []uint64, err error) ([]uint64, error)

func (*BitAnd[T1]) Fill added in v0.6.0

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

func (*BitAnd[T1]) Grows added in v0.6.0

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

func (*BitAnd[T1]) MarshalBinary added in v0.6.0

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

func (*BitAnd[T1]) Merge added in v0.6.0

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

func (*BitAnd[T1]) UnmarshalBinary added in v0.6.0

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

type BitAndBinary added in v0.8.0

type BitAndBinary struct {
}

func NewBitAndBinary added in v0.8.0

func NewBitAndBinary() *BitAndBinary

func (*BitAndBinary) Eval added in v0.8.0

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

func (*BitAndBinary) Fill added in v0.8.0

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

func (*BitAndBinary) Grows added in v0.8.0

func (bab *BitAndBinary) Grows(_ int)

func (*BitAndBinary) MarshalBinary added in v0.8.0

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

func (*BitAndBinary) Merge added in v0.8.0

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

func (*BitAndBinary) UnmarshalBinary added in v0.8.0

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

type BitOr added in v0.6.0

type BitOr[T1 types.Ints | types.UInts | types.Floats] struct {
}

func NewBitOr added in v0.6.0

func NewBitOr[T1 types.Ints | types.UInts | types.Floats]() *BitOr[T1]

func (*BitOr[T1]) Eval added in v0.6.0

func (bo *BitOr[T1]) Eval(vs []uint64, err error) ([]uint64, error)

func (*BitOr[T1]) Fill added in v0.6.0

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

func (*BitOr[T1]) Grows added in v0.6.0

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

func (*BitOr[T1]) MarshalBinary added in v0.6.0

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

func (*BitOr[T1]) Merge added in v0.6.0

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

func (*BitOr[T1]) UnmarshalBinary added in v0.6.0

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

type BitOrBinary added in v0.8.0

type BitOrBinary struct {
}

func NewBitOrBinary added in v0.8.0

func NewBitOrBinary() *BitOrBinary

func (*BitOrBinary) Eval added in v0.8.0

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

func (*BitOrBinary) Fill added in v0.8.0

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

func (*BitOrBinary) Grows added in v0.8.0

func (bab *BitOrBinary) Grows(_ int)

func (*BitOrBinary) MarshalBinary added in v0.8.0

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

func (*BitOrBinary) Merge added in v0.8.0

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

func (*BitOrBinary) UnmarshalBinary added in v0.8.0

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

type BitXor added in v0.6.0

type BitXor[T1 types.Ints | types.UInts | types.Floats] struct {
}

func NewBitXor added in v0.6.0

func NewBitXor[T1 types.Ints | types.UInts | types.Floats]() *BitXor[T1]

func (*BitXor[T1]) Eval added in v0.6.0

func (bx *BitXor[T1]) Eval(vs []uint64, err error) ([]uint64, error)

func (*BitXor[T1]) Fill added in v0.6.0

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

func (*BitXor[T1]) Grows added in v0.6.0

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

func (*BitXor[T1]) MarshalBinary added in v0.6.0

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

func (*BitXor[T1]) Merge added in v0.6.0

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

func (*BitXor[T1]) UnmarshalBinary added in v0.6.0

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

type BitXorBinary added in v0.8.0

type BitXorBinary struct {
}

func NewBitXorBinary added in v0.8.0

func NewBitXorBinary() *BitXorBinary

func (*BitXorBinary) Eval added in v0.8.0

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

func (*BitXorBinary) Fill added in v0.8.0

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

func (*BitXorBinary) Grows added in v0.8.0

func (bab *BitXorBinary) Grows(_ int)

func (*BitXorBinary) MarshalBinary added in v0.8.0

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

func (*BitXorBinary) Merge added in v0.8.0

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

func (*BitXorBinary) UnmarshalBinary added in v0.8.0

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

type BoolMax added in v0.6.0

type BoolMax struct {
}

func NewBoolMax added in v0.6.0

func NewBoolMax() *BoolMax

func (*BoolMax) Eval added in v0.6.0

func (m *BoolMax) Eval(vs []bool, err error) ([]bool, error)

func (*BoolMax) Fill added in v0.6.0

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

func (*BoolMax) Grows added in v0.6.0

func (m *BoolMax) Grows(_ int)

func (*BoolMax) MarshalBinary added in v0.6.0

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

func (*BoolMax) Merge added in v0.6.0

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

func (*BoolMax) UnmarshalBinary added in v0.6.0

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

type BoolMin added in v0.6.0

type BoolMin struct {
}

func NewBoolMin added in v0.6.0

func NewBoolMin() *BoolMin

func (*BoolMin) Eval added in v0.6.0

func (m *BoolMin) Eval(vs []bool, err error) ([]bool, error)

func (*BoolMin) Fill added in v0.6.0

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

func (*BoolMin) Grows added in v0.6.0

func (m *BoolMin) Grows(_ int)

func (*BoolMin) MarshalBinary added in v0.6.0

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

func (*BoolMin) Merge added in v0.6.0

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

func (*BoolMin) UnmarshalBinary added in v0.6.0

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

type Compare added in v0.6.0

type Count added in v0.6.0

type Count[T1 types.OrderedT | Decimal128AndString] struct {
	// IsStar is true: count(*)
	IsStar bool
}

func NewCount added in v0.6.0

func NewCount[T1 types.OrderedT | Decimal128AndString](isStar bool) *Count[T1]

func (*Count[T1]) BatchFill added in v0.8.0

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

func (*Count[T1]) Eval added in v0.6.0

func (c *Count[T1]) Eval(vs []int64, err error) ([]int64, error)

func (*Count[T1]) Fill added in v0.6.0

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

func (*Count[T1]) Grows added in v0.6.0

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

func (*Count[T1]) MarshalBinary added in v0.6.0

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

func (*Count[T1]) Merge added in v0.6.0

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

func (*Count[T1]) UnmarshalBinary added in v0.6.0

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

type Decimal128AndString added in v0.6.0

type Decimal128AndString interface {
	types.Decimal | []byte | bool | types.Uuid
}

type Decimal128Avg added in v0.6.0

type Decimal128Avg struct {
	Cnts []int64
	Typ  types.Type
}

func NewD128Avg added in v0.6.0

func NewD128Avg(typ types.Type) *Decimal128Avg

func (*Decimal128Avg) BatchFill added in v0.6.0

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

func (*Decimal128Avg) Eval added in v0.6.0

func (a *Decimal128Avg) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*Decimal128Avg) Fill added in v0.6.0

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

func (*Decimal128Avg) Grows added in v0.6.0

func (a *Decimal128Avg) Grows(cnt int)

func (*Decimal128Avg) MarshalBinary added in v0.6.0

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

func (*Decimal128Avg) Merge added in v0.6.0

func (a *Decimal128Avg) Merge(xIndex int64, yIndex int64, x types.Decimal128, y types.Decimal128, xEmpty bool, yEmpty bool, yAvg any) (types.Decimal128, bool, error)

func (*Decimal128Avg) UnmarshalBinary added in v0.6.0

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

type Decimal128Max added in v0.6.0

type Decimal128Max struct {
}

func NewD128Max added in v0.6.0

func NewD128Max() *Decimal128Max

func (*Decimal128Max) Eval added in v0.6.0

func (m *Decimal128Max) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*Decimal128Max) Fill added in v0.6.0

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

func (*Decimal128Max) Grows added in v0.6.0

func (m *Decimal128Max) Grows(_ int)

func (*Decimal128Max) MarshalBinary added in v0.6.0

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

func (*Decimal128Max) Merge added in v0.6.0

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

func (*Decimal128Max) UnmarshalBinary added in v0.6.0

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

type Decimal128Median added in v0.7.0

type Decimal128Median struct {
	Vals []decimal128Slice
}

func NewD128Median added in v0.7.0

func NewD128Median() *Decimal128Median

func (*Decimal128Median) Descriptor added in v0.8.0

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

func (*Decimal128Median) Eval added in v0.7.0

func (m *Decimal128Median) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*Decimal128Median) Fill added in v0.7.0

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

func (*Decimal128Median) Grows added in v0.7.0

func (m *Decimal128Median) Grows(cnt int)

func (*Decimal128Median) Marshal added in v0.8.0

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

func (*Decimal128Median) MarshalBinary added in v0.7.0

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

func (*Decimal128Median) MarshalTo added in v0.8.0

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

func (*Decimal128Median) MarshalToSizedBuffer added in v0.8.0

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

func (*Decimal128Median) Merge added in v0.7.0

func (m *Decimal128Median) Merge(xIndex int64, yIndex int64, _ types.Decimal128, _ types.Decimal128, xEmpty bool, yEmpty bool, yMedian any) (types.Decimal128, bool, error)

func (*Decimal128Median) ProtoMessage added in v0.8.0

func (*Decimal128Median) ProtoMessage()

func (*Decimal128Median) ProtoSize added in v0.8.0

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

func (*Decimal128Median) Reset added in v0.8.0

func (m *Decimal128Median) Reset()

func (*Decimal128Median) String added in v0.8.0

func (m *Decimal128Median) String() string

func (*Decimal128Median) Unmarshal added in v0.8.0

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

func (*Decimal128Median) UnmarshalBinary added in v0.7.0

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

func (*Decimal128Median) XXX_DiscardUnknown added in v0.8.0

func (m *Decimal128Median) XXX_DiscardUnknown()

func (*Decimal128Median) XXX_Marshal added in v0.8.0

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

func (*Decimal128Median) XXX_Merge added in v0.8.0

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

func (*Decimal128Median) XXX_Size added in v0.8.0

func (m *Decimal128Median) XXX_Size() int

func (*Decimal128Median) XXX_Unmarshal added in v0.8.0

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

type Decimal128Min added in v0.6.0

type Decimal128Min struct {
}

func NewD128Min added in v0.6.0

func NewD128Min() *Decimal128Min

func (*Decimal128Min) Eval added in v0.6.0

func (m *Decimal128Min) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*Decimal128Min) Fill added in v0.6.0

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

func (*Decimal128Min) Grows added in v0.6.0

func (m *Decimal128Min) Grows(_ int)

func (*Decimal128Min) MarshalBinary added in v0.6.0

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

func (*Decimal128Min) Merge added in v0.6.0

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

func (*Decimal128Min) UnmarshalBinary added in v0.6.0

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

type Decimal128SlicePB added in v0.8.0

type Decimal128SlicePB struct {
	Slice []github_com_matrixorigin_matrixone_pkg_container_types.Decimal128 `` /* 129-byte string literal not displayed */
}

func (*Decimal128SlicePB) Descriptor added in v0.8.0

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

func (*Decimal128SlicePB) Marshal added in v0.8.0

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

func (*Decimal128SlicePB) MarshalTo added in v0.8.0

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

func (*Decimal128SlicePB) MarshalToSizedBuffer added in v0.8.0

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

func (*Decimal128SlicePB) ProtoMessage added in v0.8.0

func (*Decimal128SlicePB) ProtoMessage()

func (*Decimal128SlicePB) ProtoSize added in v0.8.0

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

func (*Decimal128SlicePB) Reset added in v0.8.0

func (m *Decimal128SlicePB) Reset()

func (*Decimal128SlicePB) String added in v0.8.0

func (m *Decimal128SlicePB) String() string

func (*Decimal128SlicePB) Unmarshal added in v0.8.0

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

func (*Decimal128SlicePB) XXX_DiscardUnknown added in v0.8.0

func (m *Decimal128SlicePB) XXX_DiscardUnknown()

func (*Decimal128SlicePB) XXX_Marshal added in v0.8.0

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

func (*Decimal128SlicePB) XXX_Merge added in v0.8.0

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

func (*Decimal128SlicePB) XXX_Size added in v0.8.0

func (m *Decimal128SlicePB) XXX_Size() int

func (*Decimal128SlicePB) XXX_Unmarshal added in v0.8.0

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

type Decimal128Sum added in v0.6.0

type Decimal128Sum struct {
}

func NewD128Sum added in v0.6.0

func NewD128Sum() *Decimal128Sum

func (*Decimal128Sum) BatchFill added in v0.6.0

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

func (*Decimal128Sum) Eval added in v0.6.0

func (s *Decimal128Sum) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*Decimal128Sum) Fill added in v0.6.0

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

func (*Decimal128Sum) Grows added in v0.6.0

func (s *Decimal128Sum) Grows(_ int)

func (*Decimal128Sum) MarshalBinary added in v0.6.0

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

func (*Decimal128Sum) Merge added in v0.6.0

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

func (*Decimal128Sum) UnmarshalBinary added in v0.6.0

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

type Decimal64Avg added in v0.6.0

type Decimal64Avg struct {
	Cnts []int64
	Typ  types.Type
}

func NewD64Avg added in v0.6.0

func NewD64Avg(typ types.Type) *Decimal64Avg

func (*Decimal64Avg) BatchFill added in v0.6.0

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

func (*Decimal64Avg) Eval added in v0.6.0

func (a *Decimal64Avg) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*Decimal64Avg) Fill added in v0.6.0

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

func (*Decimal64Avg) Grows added in v0.6.0

func (a *Decimal64Avg) Grows(cnt int)

func (*Decimal64Avg) MarshalBinary added in v0.6.0

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

func (*Decimal64Avg) Merge added in v0.6.0

func (a *Decimal64Avg) Merge(xIndex int64, yIndex int64, x types.Decimal128, y types.Decimal128, xEmpty bool, yEmpty bool, yAvg any) (types.Decimal128, bool, error)

func (*Decimal64Avg) UnmarshalBinary added in v0.6.0

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

type Decimal64Max added in v0.6.0

type Decimal64Max struct {
}

func NewD64Max added in v0.6.0

func NewD64Max() *Decimal64Max

func (*Decimal64Max) Eval added in v0.6.0

func (m *Decimal64Max) Eval(vs []types.Decimal64, err error) ([]types.Decimal64, error)

func (*Decimal64Max) Fill added in v0.6.0

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

func (*Decimal64Max) Grows added in v0.6.0

func (m *Decimal64Max) Grows(_ int)

func (*Decimal64Max) MarshalBinary added in v0.6.0

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

func (*Decimal64Max) Merge added in v0.6.0

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

func (*Decimal64Max) UnmarshalBinary added in v0.6.0

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

type Decimal64Median added in v0.7.0

type Decimal64Median struct {
	Vals []decimal64Slice
}

func NewD64Median added in v0.7.0

func NewD64Median() *Decimal64Median

func (*Decimal64Median) Descriptor added in v0.8.0

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

func (*Decimal64Median) Eval added in v0.7.0

func (m *Decimal64Median) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*Decimal64Median) Fill added in v0.7.0

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

func (*Decimal64Median) Grows added in v0.7.0

func (m *Decimal64Median) Grows(cnt int)

func (*Decimal64Median) Marshal added in v0.8.0

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

func (*Decimal64Median) MarshalBinary added in v0.7.0

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

func (*Decimal64Median) MarshalTo added in v0.8.0

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

func (*Decimal64Median) MarshalToSizedBuffer added in v0.8.0

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

func (*Decimal64Median) Merge added in v0.7.0

func (m *Decimal64Median) Merge(xIndex int64, yIndex int64, _ types.Decimal128, _ types.Decimal128, xEmpty bool, yEmpty bool, yMedian any) (types.Decimal128, bool, error)

func (*Decimal64Median) ProtoMessage added in v0.8.0

func (*Decimal64Median) ProtoMessage()

func (*Decimal64Median) ProtoSize added in v0.8.0

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

func (*Decimal64Median) Reset added in v0.8.0

func (m *Decimal64Median) Reset()

func (*Decimal64Median) String added in v0.8.0

func (m *Decimal64Median) String() string

func (*Decimal64Median) Unmarshal added in v0.8.0

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

func (*Decimal64Median) UnmarshalBinary added in v0.7.0

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

func (*Decimal64Median) XXX_DiscardUnknown added in v0.8.0

func (m *Decimal64Median) XXX_DiscardUnknown()

func (*Decimal64Median) XXX_Marshal added in v0.8.0

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

func (*Decimal64Median) XXX_Merge added in v0.8.0

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

func (*Decimal64Median) XXX_Size added in v0.8.0

func (m *Decimal64Median) XXX_Size() int

func (*Decimal64Median) XXX_Unmarshal added in v0.8.0

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

type Decimal64Min added in v0.6.0

type Decimal64Min struct {
}

func NewD64Min added in v0.6.0

func NewD64Min() *Decimal64Min

func (*Decimal64Min) Eval added in v0.6.0

func (m *Decimal64Min) Eval(vs []types.Decimal64, err error) ([]types.Decimal64, error)

func (*Decimal64Min) Fill added in v0.6.0

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

func (*Decimal64Min) Grows added in v0.6.0

func (m *Decimal64Min) Grows(_ int)

func (*Decimal64Min) MarshalBinary added in v0.6.0

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

func (*Decimal64Min) Merge added in v0.6.0

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

func (*Decimal64Min) UnmarshalBinary added in v0.6.0

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

type Decimal64SlicePB added in v0.8.0

type Decimal64SlicePB struct {
	Slice []github_com_matrixorigin_matrixone_pkg_container_types.Decimal64 `` /* 128-byte string literal not displayed */
}

func (*Decimal64SlicePB) Descriptor added in v0.8.0

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

func (*Decimal64SlicePB) Marshal added in v0.8.0

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

func (*Decimal64SlicePB) MarshalTo added in v0.8.0

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

func (*Decimal64SlicePB) MarshalToSizedBuffer added in v0.8.0

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

func (*Decimal64SlicePB) ProtoMessage added in v0.8.0

func (*Decimal64SlicePB) ProtoMessage()

func (*Decimal64SlicePB) ProtoSize added in v0.8.0

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

func (*Decimal64SlicePB) Reset added in v0.8.0

func (m *Decimal64SlicePB) Reset()

func (*Decimal64SlicePB) String added in v0.8.0

func (m *Decimal64SlicePB) String() string

func (*Decimal64SlicePB) Unmarshal added in v0.8.0

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

func (*Decimal64SlicePB) XXX_DiscardUnknown added in v0.8.0

func (m *Decimal64SlicePB) XXX_DiscardUnknown()

func (*Decimal64SlicePB) XXX_Marshal added in v0.8.0

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

func (*Decimal64SlicePB) XXX_Merge added in v0.8.0

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

func (*Decimal64SlicePB) XXX_Size added in v0.8.0

func (m *Decimal64SlicePB) XXX_Size() int

func (*Decimal64SlicePB) XXX_Unmarshal added in v0.8.0

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

type Decimal64Sum added in v0.6.0

type Decimal64Sum struct {
}

func NewD64Sum added in v0.6.0

func NewD64Sum() *Decimal64Sum

func (*Decimal64Sum) BatchFill added in v0.6.0

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

func (*Decimal64Sum) Eval added in v0.6.0

func (s *Decimal64Sum) Eval(vs []types.Decimal64, err error) ([]types.Decimal64, error)

func (*Decimal64Sum) Fill added in v0.6.0

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

func (*Decimal64Sum) Grows added in v0.6.0

func (s *Decimal64Sum) Grows(_ int)

func (*Decimal64Sum) MarshalBinary added in v0.6.0

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

func (*Decimal64Sum) Merge added in v0.6.0

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

func (*Decimal64Sum) UnmarshalBinary added in v0.6.0

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

type DenseRank added in v0.8.0

type DenseRank struct {
	Ps [][]int64
}

func NewDenseRank added in v0.8.0

func NewDenseRank() *DenseRank

func (*DenseRank) BatchFill added in v0.8.0

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

func (*DenseRank) Eval added in v0.8.0

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

func (*DenseRank) Fill added in v0.8.0

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

func (*DenseRank) Grows added in v0.8.0

func (r *DenseRank) Grows(_ int)

func (*DenseRank) MarshalBinary added in v0.8.0

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

func (*DenseRank) Merge added in v0.8.0

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

func (*DenseRank) UnmarshalBinary added in v0.8.0

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

type EncodeAgg added in v0.6.0

type EncodeAgg struct {
	Op      int
	Private []byte
	Es      []bool
	Da      []byte

	InputTypes []byte
	OutputType []byte
	IsCount    bool
}

func (*EncodeAgg) Descriptor added in v0.8.0

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

func (*EncodeAgg) GetDa added in v0.8.0

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

func (*EncodeAgg) GetEs added in v0.8.0

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

func (*EncodeAgg) GetInputTypes added in v0.8.0

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

func (*EncodeAgg) GetIsCount added in v0.8.0

func (m *EncodeAgg) GetIsCount() bool

func (*EncodeAgg) GetOp added in v0.8.0

func (m *EncodeAgg) GetOp() int

func (*EncodeAgg) GetOutputType added in v0.8.0

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

func (*EncodeAgg) GetPrivate added in v0.8.0

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

func (*EncodeAgg) Marshal added in v0.8.0

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

func (*EncodeAgg) MarshalTo added in v0.8.0

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

func (*EncodeAgg) MarshalToSizedBuffer added in v0.8.0

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

func (*EncodeAgg) ProtoMessage added in v0.8.0

func (*EncodeAgg) ProtoMessage()

func (*EncodeAgg) ProtoSize added in v0.8.0

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

func (*EncodeAgg) Reset added in v0.8.0

func (m *EncodeAgg) Reset()

func (*EncodeAgg) String added in v0.8.0

func (m *EncodeAgg) String() string

func (*EncodeAgg) Unmarshal added in v0.8.0

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

func (*EncodeAgg) XXX_DiscardUnknown added in v0.8.0

func (m *EncodeAgg) XXX_DiscardUnknown()

func (*EncodeAgg) XXX_Marshal added in v0.8.0

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

func (*EncodeAgg) XXX_Merge added in v0.8.0

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

func (*EncodeAgg) XXX_Size added in v0.8.0

func (m *EncodeAgg) XXX_Size() int

func (*EncodeAgg) XXX_Unmarshal added in v0.8.0

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

type EncodeAggDistinct added in v0.6.0

type EncodeAggDistinct[T any] struct {
	Op      int
	Private []byte
	Es      []bool
	Da      []byte

	InputTypes []types.Type
	OutputType types.Type

	IsCount bool
	Srcs    [][]T
}

func (*EncodeAggDistinct[T]) MarshalBinary added in v0.8.0

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

func (*EncodeAggDistinct[T]) UnmarshalBinary added in v0.8.0

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

type EncodeAggDistinctPB added in v0.8.0

type EncodeAggDistinctPB struct {
	Op         int                                                          `protobuf:"varint,1,opt,name=Op,proto3,casttype=int" json:"Op,omitempty"`
	Private    []byte                                                       `protobuf:"bytes,2,opt,name=Private,proto3" json:"Private,omitempty"`
	Es         []bool                                                       `protobuf:"varint,3,rep,packed,name=Es,proto3" json:"Es,omitempty"`
	Da         []byte                                                       `protobuf:"bytes,4,opt,name=Da,proto3" json:"Da,omitempty"`
	InputTypes []github_com_matrixorigin_matrixone_pkg_container_types.Type `` /* 133-byte string literal not displayed */
	OutputType github_com_matrixorigin_matrixone_pkg_container_types.Type   `` /* 133-byte string literal not displayed */
	IsCount    bool                                                         `protobuf:"varint,7,opt,name=IsCount,proto3" json:"IsCount,omitempty"`
}

func (*EncodeAggDistinctPB) Descriptor added in v0.8.0

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

func (*EncodeAggDistinctPB) GetDa added in v0.8.0

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

func (*EncodeAggDistinctPB) GetEs added in v0.8.0

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

func (*EncodeAggDistinctPB) GetIsCount added in v0.8.0

func (m *EncodeAggDistinctPB) GetIsCount() bool

func (*EncodeAggDistinctPB) GetOp added in v0.8.0

func (m *EncodeAggDistinctPB) GetOp() int

func (*EncodeAggDistinctPB) GetPrivate added in v0.8.0

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

func (*EncodeAggDistinctPB) Marshal added in v0.8.0

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

func (*EncodeAggDistinctPB) MarshalTo added in v0.8.0

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

func (*EncodeAggDistinctPB) MarshalToSizedBuffer added in v0.8.0

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

func (*EncodeAggDistinctPB) ProtoMessage added in v0.8.0

func (*EncodeAggDistinctPB) ProtoMessage()

func (*EncodeAggDistinctPB) ProtoSize added in v0.8.0

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

func (*EncodeAggDistinctPB) Reset added in v0.8.0

func (m *EncodeAggDistinctPB) Reset()

func (*EncodeAggDistinctPB) String added in v0.8.0

func (m *EncodeAggDistinctPB) String() string

func (*EncodeAggDistinctPB) Unmarshal added in v0.8.0

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

func (*EncodeAggDistinctPB) XXX_DiscardUnknown added in v0.8.0

func (m *EncodeAggDistinctPB) XXX_DiscardUnknown()

func (*EncodeAggDistinctPB) XXX_Marshal added in v0.8.0

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

func (*EncodeAggDistinctPB) XXX_Merge added in v0.8.0

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

func (*EncodeAggDistinctPB) XXX_Size added in v0.8.0

func (m *EncodeAggDistinctPB) XXX_Size() int

func (*EncodeAggDistinctPB) XXX_Unmarshal added in v0.8.0

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

type EncodeDecimalV added in v0.6.0

type EncodeDecimalV struct {
	Sum    []types.Decimal128
	Counts []int64
}

func (*EncodeDecimalV) Descriptor added in v0.8.0

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

func (*EncodeDecimalV) GetCounts added in v0.8.0

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

func (*EncodeDecimalV) Marshal added in v0.8.0

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

func (*EncodeDecimalV) MarshalTo added in v0.8.0

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

func (*EncodeDecimalV) MarshalToSizedBuffer added in v0.8.0

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

func (*EncodeDecimalV) ProtoMessage added in v0.8.0

func (*EncodeDecimalV) ProtoMessage()

func (*EncodeDecimalV) ProtoSize added in v0.8.0

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

func (*EncodeDecimalV) Reset added in v0.8.0

func (m *EncodeDecimalV) Reset()

func (*EncodeDecimalV) String added in v0.8.0

func (m *EncodeDecimalV) String() string

func (*EncodeDecimalV) Unmarshal added in v0.8.0

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

func (*EncodeDecimalV) XXX_DiscardUnknown added in v0.8.0

func (m *EncodeDecimalV) XXX_DiscardUnknown()

func (*EncodeDecimalV) XXX_Marshal added in v0.8.0

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

func (*EncodeDecimalV) XXX_Merge added in v0.8.0

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

func (*EncodeDecimalV) XXX_Size added in v0.8.0

func (m *EncodeDecimalV) XXX_Size() int

func (*EncodeDecimalV) XXX_Unmarshal added in v0.8.0

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

type EncodeVariance added in v0.6.0

type EncodeVariance struct {
	Sum    []float64
	Counts []float64
}

func (*EncodeVariance) Descriptor added in v0.8.0

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

func (*EncodeVariance) GetCounts added in v0.8.0

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

func (*EncodeVariance) GetSum added in v0.8.0

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

func (*EncodeVariance) Marshal added in v0.8.0

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

func (*EncodeVariance) MarshalTo added in v0.8.0

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

func (*EncodeVariance) MarshalToSizedBuffer added in v0.8.0

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

func (*EncodeVariance) ProtoMessage added in v0.8.0

func (*EncodeVariance) ProtoMessage()

func (*EncodeVariance) ProtoSize added in v0.8.0

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

func (*EncodeVariance) Reset added in v0.8.0

func (m *EncodeVariance) Reset()

func (*EncodeVariance) String added in v0.8.0

func (m *EncodeVariance) String() string

func (*EncodeVariance) Unmarshal added in v0.8.0

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

func (*EncodeVariance) XXX_DiscardUnknown added in v0.8.0

func (m *EncodeVariance) XXX_DiscardUnknown()

func (*EncodeVariance) XXX_Marshal added in v0.8.0

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

func (*EncodeVariance) XXX_Merge added in v0.8.0

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

func (*EncodeVariance) XXX_Size added in v0.8.0

func (m *EncodeVariance) XXX_Size() int

func (*EncodeVariance) XXX_Unmarshal added in v0.8.0

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

type Max added in v0.6.0

type Max[T Compare] struct {
}

func NewMax added in v0.6.0

func NewMax[T Compare]() *Max[T]

func (*Max[T]) Eval added in v0.6.0

func (m *Max[T]) Eval(vs []T, err error) ([]T, error)

func (*Max[T]) Fill added in v0.6.0

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

func (*Max[T]) Grows added in v0.6.0

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

func (*Max[T]) MarshalBinary added in v0.6.0

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

func (*Max[T]) Merge added in v0.6.0

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

func (*Max[T]) UnmarshalBinary added in v0.6.0

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

type Median added in v0.7.0

type Median[T Numeric] struct {
	Vals []numericSlice[T]
}

func NewMedian added in v0.7.0

func NewMedian[T Numeric]() *Median[T]

func (*Median[T]) Eval added in v0.7.0

func (m *Median[T]) Eval(vs []float64, err error) ([]float64, error)

func (*Median[T]) Fill added in v0.7.0

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

func (*Median[T]) Grows added in v0.7.0

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

func (*Median[T]) MarshalBinary added in v0.7.0

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

func (*Median[T]) Merge added in v0.7.0

func (m *Median[T]) Merge(xIndex int64, yIndex int64, _ float64, _ float64, xEmpty bool, yEmpty bool, yMedian any) (float64, bool, error)

func (*Median[T]) UnmarshalBinary added in v0.7.0

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

type Min added in v0.6.0

type Min[T Compare] struct {
}

func NewMin added in v0.6.0

func NewMin[T Compare]() *Min[T]

func (*Min[T]) Eval added in v0.6.0

func (m *Min[T]) Eval(vs []T, err error) ([]T, error)

func (*Min[T]) Fill added in v0.6.0

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

func (*Min[T]) Grows added in v0.6.0

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

func (*Min[T]) MarshalBinary added in v0.6.0

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

func (*Min[T]) Merge added in v0.6.0

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

func (*Min[T]) UnmarshalBinary added in v0.6.0

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

type Numeric added in v0.6.0

type Numeric interface {
	types.Ints | types.UInts | types.Floats
}

type Rank added in v0.8.0

type Rank struct {
	Ps [][]int64
}

func NewRank added in v0.8.0

func NewRank() *Rank

func (*Rank) BatchFill added in v0.8.0

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

func (*Rank) Eval added in v0.8.0

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

func (*Rank) Fill added in v0.8.0

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

func (*Rank) Grows added in v0.8.0

func (r *Rank) Grows(_ int)

func (*Rank) MarshalBinary added in v0.8.0

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

func (*Rank) Merge added in v0.8.0

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

func (*Rank) UnmarshalBinary added in v0.8.0

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

type ReturnTyp added in v0.6.0

type ReturnTyp interface {
	uint64 | int64 | float64
}

if input type is int8/int16/int32/int64, the return type is int64 if input type is uint8/uint16/uint32/uint64, the return type is uint64 f input type is float32/float64, the return type is float64

type RowNumber added in v0.8.0

type RowNumber struct {
	Ps [][]int64
}

func NewRowNumber added in v0.8.0

func NewRowNumber() *RowNumber

func (*RowNumber) BatchFill added in v0.8.0

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

func (*RowNumber) Eval added in v0.8.0

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

func (*RowNumber) Fill added in v0.8.0

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

func (*RowNumber) Grows added in v0.8.0

func (r *RowNumber) Grows(_ int)

func (*RowNumber) MarshalBinary added in v0.8.0

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

func (*RowNumber) Merge added in v0.8.0

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

func (*RowNumber) UnmarshalBinary added in v0.8.0

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

type StdD128 added in v0.6.0

type StdD128 struct {
	Variance *VD128
	Typ      types.Type
}

func NewStdD128 added in v0.6.0

func NewStdD128(typ types.Type) *StdD128

func (*StdD128) Eval added in v0.6.0

func (s *StdD128) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*StdD128) Fill added in v0.6.0

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

func (*StdD128) Grows added in v0.6.0

func (s *StdD128) Grows(size int)

func (*StdD128) MarshalBinary added in v0.6.0

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

func (*StdD128) Merge added in v0.6.0

func (s *StdD128) Merge(groupIndex1, groupIndex2 int64, x, y types.Decimal128, IsEmpty1 bool, IsEmpty2 bool, agg any) (types.Decimal128, bool, error)

func (*StdD128) UnmarshalBinary added in v0.6.0

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

type StdD64 added in v0.6.0

type StdD64 struct {
	Variance *VD64
	Typ      types.Type
}

func NewStdD64 added in v0.6.0

func NewStdD64(typ types.Type) *StdD64

func (*StdD64) Eval added in v0.6.0

func (s *StdD64) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*StdD64) Fill added in v0.6.0

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

func (*StdD64) Grows added in v0.6.0

func (s *StdD64) Grows(size int)

func (*StdD64) MarshalBinary added in v0.6.0

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

func (*StdD64) Merge added in v0.6.0

func (s *StdD64) Merge(groupIndex1, groupIndex2 int64, x, y types.Decimal128, IsEmpty1 bool, IsEmpty2 bool, agg any) (types.Decimal128, bool, error)

func (*StdD64) UnmarshalBinary added in v0.6.0

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

type Stddevpop added in v0.6.0

type Stddevpop[T1 types.Floats | types.Ints | types.UInts] struct {
	Variance *Variance[T1]
}

func NewStdDevPop added in v0.6.0

func NewStdDevPop[T1 types.Floats | types.Ints | types.UInts]() *Stddevpop[T1]

NewStdDevPop is used to create a StdDevPop which supports float,int,uint

func (*Stddevpop[T1]) Eval added in v0.6.0

func (sdp *Stddevpop[T1]) Eval(vs []float64, err error) ([]float64, error)

func (*Stddevpop[T1]) Fill added in v0.6.0

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

func (*Stddevpop[T1]) Grows added in v0.6.0

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

func (*Stddevpop[T1]) MarshalBinary added in v0.6.0

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

func (*Stddevpop[T1]) Merge added in v0.6.0

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

func (*Stddevpop[T1]) UnmarshalBinary added in v0.6.0

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

type StrAnyvalue added in v0.8.0

type StrAnyvalue struct {
	NotSet []bool
}

func NewStrAnyValue added in v0.8.0

func NewStrAnyValue() *StrAnyvalue

func (*StrAnyvalue) Eval added in v0.8.0

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

func (*StrAnyvalue) Fill added in v0.8.0

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

func (*StrAnyvalue) Grows added in v0.8.0

func (a *StrAnyvalue) Grows(size int)

func (*StrAnyvalue) MarshalBinary added in v0.8.0

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

func (*StrAnyvalue) Merge added in v0.8.0

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

func (*StrAnyvalue) UnmarshalBinary added in v0.8.0

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

type StrMax added in v0.6.0

type StrMax struct {
}

func NewStrMax added in v0.6.0

func NewStrMax() *StrMax

func (*StrMax) Eval added in v0.6.0

func (m *StrMax) Eval(vs [][]byte, err error) ([][]byte, error)

func (*StrMax) Fill added in v0.6.0

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

func (*StrMax) Grows added in v0.6.0

func (m *StrMax) Grows(_ int)

func (*StrMax) MarshalBinary added in v0.6.0

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

func (*StrMax) Merge added in v0.6.0

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

func (*StrMax) UnmarshalBinary added in v0.6.0

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

type StrMin added in v0.6.0

type StrMin struct {
}

func NewStrMin added in v0.6.0

func NewStrMin() *StrMin

func (*StrMin) Eval added in v0.6.0

func (m *StrMin) Eval(vs [][]byte, err error) ([][]byte, error)

func (*StrMin) Fill added in v0.6.0

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

func (*StrMin) Grows added in v0.6.0

func (m *StrMin) Grows(_ int)

func (*StrMin) MarshalBinary added in v0.6.0

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

func (*StrMin) Merge added in v0.6.0

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

func (*StrMin) UnmarshalBinary added in v0.6.0

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

type Sum added in v0.6.0

type Sum[T1 Numeric, T2 ReturnTyp] struct {
}

func NewSum added in v0.6.0

func NewSum[T1 Numeric, T2 ReturnTyp]() *Sum[T1, T2]

func (*Sum[T1, T2]) Eval added in v0.6.0

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

func (*Sum[T1, T2]) Fill added in v0.6.0

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

func (*Sum[T1, T2]) Grows added in v0.6.0

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

func (*Sum[T1, T2]) MarshalBinary added in v0.6.0

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

func (*Sum[T1, T2]) Merge added in v0.6.0

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

func (*Sum[T1, T2]) UnmarshalBinary added in v0.6.0

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

type UnaryAgg

type UnaryAgg[T1, T2 any] struct {
	// contains filtered or unexported fields
}

UnaryAgg generic aggregation function with one input vector and without distinct

func (*UnaryAgg[T1, T2]) BatchFill

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

func (*UnaryAgg[T1, T2]) BatchMerge

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

func (*UnaryAgg[T1, T2]) BulkFill

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

func (*UnaryAgg[T1, T2]) Dup

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

func (*UnaryAgg[T1, T2]) Eval

func (a *UnaryAgg[T1, T2]) Eval(m *mpool.MPool) (*vector.Vector, error)

func (*UnaryAgg[T1, T2]) Fill

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

func (*UnaryAgg[T1, T2]) Free

func (a *UnaryAgg[T1, T2]) Free(m *mpool.MPool)

func (*UnaryAgg[T1, T2]) GetInputTypes added in v0.6.0

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

func (*UnaryAgg[T1, T2]) GetOperatorId added in v0.6.0

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

func (*UnaryAgg[T1, T2]) Grows

func (a *UnaryAgg[T1, T2]) Grows(size int, m *mpool.MPool) error

func (*UnaryAgg[T1, T2]) InputTypes

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

func (*UnaryAgg[T1, T2]) IsDistinct added in v0.6.0

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

func (*UnaryAgg[T1, T2]) MarshalBinary added in v0.6.0

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

func (*UnaryAgg[T1, T2]) Merge

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

Merge a[x] += b[y]

func (*UnaryAgg[T1, T2]) OutputType

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

func (*UnaryAgg[T1, T2]) String

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

func (*UnaryAgg[T1, T2]) UnmarshalBinary added in v0.6.0

func (a *UnaryAgg[T1, T2]) UnmarshalBinary(data []byte) error

func (*UnaryAgg[T1, T2]) WildAggReAlloc added in v0.6.0

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

type UnaryDistAgg

type UnaryDistAgg[T1, T2 any] struct {
	// contains filtered or unexported fields
}

UnaryDistAgg generic aggregation function with one input vector and with distinct

func (*UnaryDistAgg[T1, T2]) BatchFill

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

func (*UnaryDistAgg[T1, T2]) BatchMerge

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

func (*UnaryDistAgg[T1, T2]) BulkFill

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

func (*UnaryDistAgg[T1, T2]) Dup

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

func (*UnaryDistAgg[T1, T2]) Eval

func (a *UnaryDistAgg[T1, T2]) Eval(m *mpool.MPool) (*vector.Vector, error)

func (*UnaryDistAgg[T1, T2]) Fill

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

func (*UnaryDistAgg[T1, T2]) Free

func (a *UnaryDistAgg[T1, T2]) Free(m *mpool.MPool)

func (*UnaryDistAgg[T1, T2]) GetInputTypes added in v0.6.0

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

func (*UnaryDistAgg[T1, T2]) GetOperatorId added in v0.6.0

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

func (*UnaryDistAgg[T1, T2]) Grows

func (a *UnaryDistAgg[T1, T2]) Grows(size int, m *mpool.MPool) error

func (*UnaryDistAgg[T1, T2]) InputTypes

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

func (*UnaryDistAgg[T1, T2]) IsDistinct added in v0.6.0

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

func (*UnaryDistAgg[T1, T2]) MarshalBinary added in v0.6.0

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

func (*UnaryDistAgg[T1, T2]) Merge

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

Merge a[x] += b[y]

func (*UnaryDistAgg[T1, T2]) OutputType

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

func (*UnaryDistAgg[T1, T2]) String

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

func (*UnaryDistAgg[T1, T2]) UnmarshalBinary added in v0.6.0

func (a *UnaryDistAgg[T1, T2]) UnmarshalBinary(data []byte) error

func (*UnaryDistAgg[T1, T2]) WildAggReAlloc added in v0.6.0

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

type UuidMax added in v0.6.0

type UuidMax struct {
}

func NewUuidMax added in v0.6.0

func NewUuidMax() *UuidMax

func (*UuidMax) Eval added in v0.6.0

func (m *UuidMax) Eval(vs []types.Uuid, err error) ([]types.Uuid, error)

func (*UuidMax) Fill added in v0.6.0

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

func (*UuidMax) Grows added in v0.6.0

func (m *UuidMax) Grows(_ int)

func (*UuidMax) MarshalBinary added in v0.6.0

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

func (*UuidMax) Merge added in v0.6.0

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

func (*UuidMax) UnmarshalBinary added in v0.6.0

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

type UuidMin added in v0.6.0

type UuidMin struct {
}

func NewUuidMin added in v0.6.0

func NewUuidMin() *UuidMin

func (*UuidMin) Eval added in v0.6.0

func (m *UuidMin) Eval(vs []types.Uuid, err error) ([]types.Uuid, error)

func (*UuidMin) Fill added in v0.6.0

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

func (*UuidMin) Grows added in v0.6.0

func (m *UuidMin) Grows(_ int)

func (*UuidMin) MarshalBinary added in v0.6.0

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

func (*UuidMin) Merge added in v0.6.0

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

func (*UuidMin) UnmarshalBinary added in v0.6.0

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

type VD128 added in v0.6.0

type VD128 struct {
	Sum         []types.Decimal128
	Counts      []int64
	Typ         types.Type
	ScaleMul    int32
	ScaleDiv    int32
	ScaleMulDiv int32
	ScaleDivMul int32
}

VD128 Variance for decimal128

func NewVD128 added in v0.6.0

func NewVD128(typ types.Type) *VD128

func (*VD128) Descriptor added in v0.8.0

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

func (*VD128) Eval added in v0.6.0

func (v *VD128) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*VD128) Fill added in v0.6.0

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

func (*VD128) GetCounts added in v0.8.0

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

func (*VD128) GetScaleDiv added in v0.8.0

func (m *VD128) GetScaleDiv() int32

func (*VD128) GetScaleDivMul added in v0.8.0

func (m *VD128) GetScaleDivMul() int32

func (*VD128) GetScaleMul added in v0.8.0

func (m *VD128) GetScaleMul() int32

func (*VD128) GetScaleMulDiv added in v0.8.0

func (m *VD128) GetScaleMulDiv() int32

func (*VD128) Grows added in v0.6.0

func (v *VD128) Grows(cnt int)

func (*VD128) Marshal added in v0.8.0

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

func (*VD128) MarshalBinary added in v0.6.0

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

func (*VD128) MarshalTo added in v0.8.0

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

func (*VD128) MarshalToSizedBuffer added in v0.8.0

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

func (*VD128) Merge added in v0.6.0

func (v *VD128) Merge(xIndex, yIndex int64, x types.Decimal128, y types.Decimal128, xEmpty bool, yEmpty bool, agg any) (types.Decimal128, bool, error)

func (*VD128) ProtoMessage added in v0.8.0

func (*VD128) ProtoMessage()

func (*VD128) ProtoSize added in v0.8.0

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

func (*VD128) Reset added in v0.8.0

func (m *VD128) Reset()

func (*VD128) String added in v0.8.0

func (m *VD128) String() string

func (*VD128) Unmarshal added in v0.8.0

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

func (*VD128) UnmarshalBinary added in v0.6.0

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

func (*VD128) XXX_DiscardUnknown added in v0.8.0

func (m *VD128) XXX_DiscardUnknown()

func (*VD128) XXX_Marshal added in v0.8.0

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

func (*VD128) XXX_Merge added in v0.8.0

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

func (*VD128) XXX_Size added in v0.8.0

func (m *VD128) XXX_Size() int

func (*VD128) XXX_Unmarshal added in v0.8.0

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

type VD64 added in v0.6.0

type VD64 struct {
	Sum         []types.Decimal128
	Counts      []int64
	Typ         types.Type
	ScaleMul    int32
	ScaleDiv    int32
	ScaleMulDiv int32
	ScaleDivMul int32
}

VD64 Variance for decimal64

func NewVD64 added in v0.6.0

func NewVD64(typ types.Type) *VD64

func (*VD64) Descriptor added in v0.8.0

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

func (*VD64) Eval added in v0.6.0

func (v *VD64) Eval(vs []types.Decimal128, err error) ([]types.Decimal128, error)

func (*VD64) Fill added in v0.6.0

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

func (*VD64) GetCounts added in v0.8.0

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

func (*VD64) GetScaleDiv added in v0.8.0

func (m *VD64) GetScaleDiv() int32

func (*VD64) GetScaleDivMul added in v0.8.0

func (m *VD64) GetScaleDivMul() int32

func (*VD64) GetScaleMul added in v0.8.0

func (m *VD64) GetScaleMul() int32

func (*VD64) GetScaleMulDiv added in v0.8.0

func (m *VD64) GetScaleMulDiv() int32

func (*VD64) Grows added in v0.6.0

func (v *VD64) Grows(cnt int)

func (*VD64) Marshal added in v0.8.0

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

func (*VD64) MarshalBinary added in v0.6.0

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

func (*VD64) MarshalTo added in v0.8.0

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

func (*VD64) MarshalToSizedBuffer added in v0.8.0

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

func (*VD64) Merge added in v0.6.0

func (v *VD64) Merge(xIndex, yIndex int64, x types.Decimal128, y types.Decimal128, xEmpty bool, yEmpty bool, agg any) (types.Decimal128, bool, error)

func (*VD64) ProtoMessage added in v0.8.0

func (*VD64) ProtoMessage()

func (*VD64) ProtoSize added in v0.8.0

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

func (*VD64) Reset added in v0.8.0

func (m *VD64) Reset()

func (*VD64) String added in v0.8.0

func (m *VD64) String() string

func (*VD64) Unmarshal added in v0.8.0

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

func (*VD64) UnmarshalBinary added in v0.6.0

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

func (*VD64) XXX_DiscardUnknown added in v0.8.0

func (m *VD64) XXX_DiscardUnknown()

func (*VD64) XXX_Marshal added in v0.8.0

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

func (*VD64) XXX_Merge added in v0.8.0

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

func (*VD64) XXX_Size added in v0.8.0

func (m *VD64) XXX_Size() int

func (*VD64) XXX_Unmarshal added in v0.8.0

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

type Variance added in v0.6.0

type Variance[T1 types.Floats | types.Ints | types.UInts] struct {
	Sum    []float64
	Counts []float64
}

func NewVariance added in v0.6.0

func NewVariance[T1 types.Floats | types.Ints | types.UInts]() *Variance[T1]

NewVariance is used to create a Variance which supports float,int,uint

func (*Variance[T1]) Eval added in v0.6.0

func (variance *Variance[T1]) Eval(vs []float64, err error) ([]float64, error)

func (*Variance[T1]) Fill added in v0.6.0

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

func (*Variance[T1]) Grows added in v0.6.0

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

func (*Variance[T1]) MarshalBinary added in v0.6.0

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

func (*Variance[T1]) Merge added in v0.6.0

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

func (*Variance[T1]) UnmarshalBinary added in v0.6.0

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

type VariancePB added in v0.8.0

type VariancePB struct {
	Sum    []float64 `protobuf:"fixed64,1,rep,packed,name=Sum,proto3" json:"Sum,omitempty"`
	Counts []float64 `protobuf:"fixed64,2,rep,packed,name=Counts,proto3" json:"Counts,omitempty"`
}

func (*VariancePB) Descriptor added in v0.8.0

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

func (*VariancePB) GetCounts added in v0.8.0

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

func (*VariancePB) GetSum added in v0.8.0

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

func (*VariancePB) Marshal added in v0.8.0

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

func (*VariancePB) MarshalTo added in v0.8.0

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

func (*VariancePB) MarshalToSizedBuffer added in v0.8.0

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

func (*VariancePB) ProtoMessage added in v0.8.0

func (*VariancePB) ProtoMessage()

func (*VariancePB) ProtoSize added in v0.8.0

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

func (*VariancePB) Reset added in v0.8.0

func (m *VariancePB) Reset()

func (*VariancePB) String added in v0.8.0

func (m *VariancePB) String() string

func (*VariancePB) Unmarshal added in v0.8.0

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

func (*VariancePB) XXX_DiscardUnknown added in v0.8.0

func (m *VariancePB) XXX_DiscardUnknown()

func (*VariancePB) XXX_Marshal added in v0.8.0

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

func (*VariancePB) XXX_Merge added in v0.8.0

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

func (*VariancePB) XXX_Size added in v0.8.0

func (m *VariancePB) XXX_Size() int

func (*VariancePB) XXX_Unmarshal added in v0.8.0

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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