agg

package
v1.0.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Aug 24, 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 AnyValueSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_date, types.T_datetime,
	types.T_timestamp, types.T_time,
	types.T_decimal64, types.T_decimal128,
	types.T_bool,
	types.T_varchar, types.T_char, types.T_blob, types.T_text,
	types.T_uuid,
	types.T_binary, types.T_varbinary,
}
View Source 
var AvgSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_decimal64, types.T_decimal128,
}
View Source 
var BitAndSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_decimal64, types.T_decimal128,
	types.T_binary, types.T_varbinary,
}
View Source 
var BitOrSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_decimal64, types.T_decimal128,
	types.T_binary, types.T_varbinary,
}
View Source 
var BitXorSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_decimal64, types.T_decimal128,
	types.T_binary, types.T_varbinary,
}
View Source 
var MaxSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_date, types.T_datetime,
	types.T_timestamp, types.T_time,
	types.T_decimal64, types.T_decimal128,
	types.T_bool,
	types.T_varchar, types.T_char, types.T_blob, types.T_text,
	types.T_uuid,
	types.T_binary, types.T_varbinary,
}
View Source 
var MedianSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_decimal64, types.T_decimal128,
}
View Source 
var MinSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_date, types.T_datetime,
	types.T_timestamp, types.T_time,
	types.T_decimal64, types.T_decimal128,
	types.T_bool,
	types.T_varchar, types.T_char, types.T_blob, types.T_text,
	types.T_uuid,
	types.T_binary, types.T_varbinary,
}
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",
}
View Source 
var StdDevPopSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_decimal64, types.T_decimal128,
}
View Source 
var SumSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_decimal64, types.T_decimal128,
}
View Source 
var VarianceSupported = []types.T{
	types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64,
	types.T_int8, types.T_int16, types.T_int32, types.T_int64,
	types.T_float32, types.T_float64,
	types.T_decimal64, types.T_decimal128,
}

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 GetFunctionIsWinOrderFunBySpecialId 

func GetFunctionIsWinOrderFunBySpecialId(id int) bool

TODO: It's a bad hack here, I will fix it later. remove the special id from agg framwork is a better way. just put these code here for now because I have no enough time to solve the import cycle problem.

func GroupConcatReturnType 

func GroupConcatReturnType(parameters []types.Type) 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

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

	// InputTypes return the input types of the agg.
	InputTypes() []types.Type

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

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

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

	// Fill use the one row of vector to fill agg.
	Fill(groupIndex int64, rowIndex int64, vectors []*vector.Vector) error

	// BulkFill use whole vector to fill agg.
	BulkFill(groupIndex int64, vectors []*vector.Vector) error

	// BatchFill use part rows of the vector to fill agg.
	// the rows are start from offset and end at offset+len(groupStatus)
	// groupOfRows[i] is 1 means that the (i+offset)th row matched the first group and 0 means not matched.
	BatchFill(offset int64, groupStatus []uint8, groupOfRows []uint64, vectors []*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
	// groupIdxes[i] is 1 means that the (offset + i)th group of agg2 matched the first group and 0 means not matched.
	BatchMerge(agg2 Agg[any], offset int64, groupStatus []uint8, groupIdxes []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 NewGroupConcat 

func NewGroupConcat(typ types.Type, dist bool, config any) Agg[any]

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, *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]]

func NewWithConfig 

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

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
	Config []byte
}

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 Compare interface {
	constraints.Integer | constraints.Float | types.Date |
		types.Datetime | types.Timestamp
}

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, 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, nsp *nulls.Nulls) (err 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, nsp *nulls.Nulls) (err 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, nsp *nulls.Nulls) (err 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, nsp *nulls.Nulls) (err 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
	OutOfRangeButOnlyOneRow error
}

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
	OutOfRangeButOnlyOneRow error
}

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 GroupConcat 

type GroupConcat struct {
	// contains filtered or unexported fields
}

func (*GroupConcat) Eval 

func (g *GroupConcat) Eval(vs [][]byte, err error) ([][]byte, error)

func (*GroupConcat) Fill 

func (g *GroupConcat) Fill(groupIndex int64, input []byte, oldValue []byte, z int64, isEmpty bool, isNull bool) ([]byte, bool, error)

func (*GroupConcat) Grows 

func (g *GroupConcat) Grows(cnt int)

func (*GroupConcat) MarshalBinary 

func (g *GroupConcat) MarshalBinary() ([]byte, error)

func (*GroupConcat) Merge 

func (g *GroupConcat) Merge(xIndex int64, yIndex int64, x []byte, y []byte, xIsEmpty bool, yIsEmpty bool, yGroupConcat any) ([]byte, bool, error)

func (*GroupConcat) UnmarshalBinary 

func (g *GroupConcat) UnmarshalBinary(odata []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(offset int64, groupStatus []uint8, groupOfRows []uint64, vectors []*vector.Vector) (err error)

func (*UnaryAgg[T1, T2]) BatchMerge 

func (a *UnaryAgg[T1, T2]) BatchMerge(b Agg[any], offset int64, groupStatus []uint8, groupIdxes []uint64) (err error)

func (*UnaryAgg[T1, T2]) BulkFill 

func (a *UnaryAgg[T1, T2]) BulkFill(groupIdx int64, vectors []*vector.Vector) (err error)

func (*UnaryAgg[T1, T2]) Eval 

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

func (*UnaryAgg[T1, T2]) Fill 

func (a *UnaryAgg[T1, T2]) Fill(groupIdx int64, rowIndex int64, vectors []*vector.Vector) (err error)

func (*UnaryAgg[T1, T2]) Free 

func (a *UnaryAgg[T1, T2]) Free(pool *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(count int, pool *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], groupIdx1, groupIdx2 int64) (err error)

Merge a[x] += b[y]

func (*UnaryAgg[T1, T2]) OutputType 

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

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(offset int64, groupStatus []uint8, groupOfRows []uint64, vectors []*vector.Vector) (err error)

func (*UnaryDistAgg[T1, T2]) BatchMerge 

func (a *UnaryDistAgg[T1, T2]) BatchMerge(b Agg[any], offset int64, groupStatus []uint8, groupIdxes []uint64) (err error)

func (*UnaryDistAgg[T1, T2]) BulkFill 

func (a *UnaryDistAgg[T1, T2]) BulkFill(groupIdx int64, vectors []*vector.Vector) (err error)

func (*UnaryDistAgg[T1, T2]) Eval 

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

func (*UnaryDistAgg[T1, T2]) Fill 

func (a *UnaryDistAgg[T1, T2]) Fill(groupIdx int64, rowIndex int64, vectors []*vector.Vector) (err error)

func (*UnaryDistAgg[T1, T2]) Free 

func (a *UnaryDistAgg[T1, T2]) Free(pool *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(count int, pool *mpool.MPool) (err 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], groupIdx1, groupIdx2 int64) (err error)

Merge a[x] += b[y]

func (*UnaryDistAgg[T1, T2]) OutputType 

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

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
	OutOfRangeButOnlyOneRow error
}

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
	OutOfRangeButOnlyOneRow error
}

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.