functionAgg

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// any_value() supported input type and output type.
	AggAnyValueSupportedParameters = []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,
		types.T_Rowid,
	}
	AggAnyValueReturnType = func(typs []types.Type) types.Type {
		return typs[0]
	}
)
View Source 
var (
	AggAvgSupportedParameters = []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,
	}
	AggAvgReturnType = func(typs []types.Type) types.Type {
		switch typs[0].Oid {
		case types.T_decimal64:
			s := int32(12)
			if s < typs[0].Scale {
				s = typs[0].Scale
			}
			if s > typs[0].Scale+6 {
				s = typs[0].Scale + 6
			}
			return types.New(types.T_decimal128, 18, s)
		case types.T_decimal128:
			s := int32(12)
			if s < typs[0].Scale {
				s = typs[0].Scale
			}
			if s > typs[0].Scale+6 {
				s = typs[0].Scale + 6
			}
			return types.New(types.T_decimal128, 18, s)
		case types.T_float32, types.T_float64:
			return types.New(types.T_float64, 0, 0)
		case types.T_int8, types.T_int16, types.T_int32, types.T_int64:
			return types.New(types.T_float64, 0, 0)
		case types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64:
			return types.New(types.T_float64, 0, 0)
		}
		panic(moerr.NewInternalErrorNoCtx("unsupported type '%v' for avg", typs[0]))
	}
)
View Source 
var (
	// bit_and() supported input type and output type.
	AggBitAndSupportedParameters = []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_binary, types.T_varbinary,
	}
	AggBitAndReturnType = func(typs []types.Type) types.Type {
		if typs[0].Oid == types.T_binary || typs[0].Oid == types.T_varbinary {
			return typs[0]
		}
		return types.New(types.T_uint64, 0, 0)
	}
)
View Source 
var (
	// bit_or() supported input type and output type.
	AggBitOrSupportedParameters = []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_binary, types.T_varbinary,
	}
	AggBitOrReturnType = AggBitAndReturnType
)
View Source 
var (
	// bit_xor() supported input type and output type.
	AggBitXorSupportedParameters = []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_binary, types.T_varbinary,
	}
	AggBitXorReturnType = AggBitAndReturnType
)
View Source 
var (
	AggClusterCentersSupportedParameters = []types.T{
		types.T_array_float32, types.T_array_float64,
	}

	AggClusterCentersReturnType = func(typs []types.Type) types.Type {
		return types.T_varchar.ToType()
	}
)
View Source 
var (
	AggMaxSupportedParameters = []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,
	}
	AggMaxReturnType = func(typs []types.Type) types.Type {
		return typs[0]
	}
)
View Source 
var (
	// median() supported input type and output type.
	AggMedianSupportedParameters = []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,
	}
	AggMedianReturnType = func(typs []types.Type) types.Type {
		switch typs[0].Oid {
		case types.T_decimal64:
			return types.New(types.T_decimal128, 38, typs[0].Scale+1)
		case types.T_decimal128:
			return types.New(types.T_decimal128, 38, typs[0].Scale+1)
		case types.T_float32, types.T_float64:
			return types.New(types.T_float64, 0, 0)
		case types.T_int8, types.T_int16, types.T_int32, types.T_int64:
			return types.New(types.T_float64, 0, 0)
		case types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64:
			return types.New(types.T_float64, 0, 0)
		}
		panic(moerr.NewInternalErrorNoCtx("unsupported type '%v' for median", typs[0]))
	}
)
View Source 
var (
	AggMinSupportedParameters = []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,
	}
	AggMinxReturnType = func(typs []types.Type) types.Type {
		return typs[0]
	}
)
View Source 
var (
	// stddev_pop() supported input type and output type.
	AggStdDevSupportedParameters = []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,
	}
	AggStdDevReturnType = AggVarianceReturnType
)
View Source 
var (
	AggSumSupportedParameters = []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,
	}
	AggSumReturnType = func(typs []types.Type) types.Type {
		switch typs[0].Oid {
		case types.T_float32, types.T_float64:
			return types.T_float64.ToType()
		case types.T_int8, types.T_int16, types.T_int32, types.T_int64:
			return types.T_int64.ToType()
		case types.T_uint8, types.T_uint16, types.T_uint32, types.T_uint64:
			return types.T_uint64.ToType()
		case types.T_decimal64:
			return types.New(types.T_decimal64, 18, typs[0].Scale)
		case types.T_decimal128:
			return types.New(types.T_decimal128, 38, typs[0].Scale)
		}
		panic(moerr.NewInternalErrorNoCtx("unsupported type '%v' for sum", typs[0]))
	}
)
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 (
	// variance() supported input type and output type.
	AggVarianceSupportedParameters = []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,
	}
	AggVarianceReturnType = func(typs []types.Type) types.Type {
		if typs[0].IsDecimal() {
			s := int32(12)
			if typs[0].Scale > s {
				s = typs[0].Scale
			}
			return types.New(types.T_decimal128, 38, s)
		}
		return types.New(types.T_float64, 0, 0)
	}
)
View Source 
var (
	// approx_count() supported input type and output type.
	AggApproxCountReturnType = func(typs []types.Type) types.Type {
		return types.T_uint64.ToType()
	}
)
View Source 
var (
	// count() supported input type and output type.
	AggCountReturnType = func(typs []types.Type) types.Type {
		return types.T_int64.ToType()
	}
)
View Source 
var (
	// group_concat() supported input type and output type.
	AggGroupConcatReturnType = func(typs []types.Type) types.Type {
		for _, p := range typs {
			if p.Oid == types.T_binary || p.Oid == types.T_varbinary || p.Oid == types.T_blob {
				return types.T_blob.ToType()
			}
		}
		return types.T_text.ToType()
	}
)
View Source 
var (
	// dense_rank() supported input type and output type.
	WinDenseRankReturnType = func(typs []types.Type) types.Type {
		return types.T_int64.ToType()
	}
)
View Source 
var (
	// rank() supported input type and output type.
	WinRankReturnType = func(typs []types.Type) types.Type {
		return types.T_int64.ToType()
	}
)
View Source 
var (
	// row_number() supported input type and output type.
	WinRowNumberReturnType = func(typs []types.Type) types.Type {
		return types.T_int64.ToType()
	}
)

Functions

func NewAggAnyValue 

func NewAggAnyValue(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggApproxCount 

func NewAggApproxCount(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggAvg 

func NewAggAvg(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggBitAnd 

func NewAggBitAnd(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggBitOr 

func NewAggBitOr(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggBitXor 

func NewAggBitXor(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggClusterCenters added in v1.1.0 

func NewAggClusterCenters(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, config any) (agg.Agg[any], error)

NewAggClusterCenters this agg func will take a vector/array column and run clustering algorithm like kmeans and return the 'k' centroids.

func NewAggCount 

func NewAggCount(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggGroupConcat 

func NewAggGroupConcat(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, config any) (agg.Agg[any], error)

func NewAggMax 

func NewAggMax(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggMedian 

func NewAggMedian(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggMin 

func NewAggMin(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggStarCount 

func NewAggStarCount(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggStdDevPop 

func NewAggStdDevPop(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggSum 

func NewAggSum(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewAggVarPop 

func NewAggVarPop(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewWinDenseRank 

func NewWinDenseRank(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewWinRank 

func NewWinRank(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

func NewWinRowNumber 

func NewWinRowNumber(overloadID int64, dist bool, inputTypes []types.Type, outputType types.Type, _ any) (agg.Agg[any], error)

Types

type Decimal128Median 

type Decimal128Median struct {
	Vals []decimal128Slice `protobuf:"bytes,1,rep,name=Vals,proto3,customtype=decimal128Slice" json:"Vals"`
}

func (*Decimal128Median) Descriptor 

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

func (*Decimal128Median) Marshal 

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

func (*Decimal128Median) MarshalTo 

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

func (*Decimal128Median) MarshalToSizedBuffer 

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

func (*Decimal128Median) ProtoMessage 

func (*Decimal128Median) ProtoMessage()

func (*Decimal128Median) ProtoSize 

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

func (*Decimal128Median) Reset 

func (m *Decimal128Median) Reset()

func (*Decimal128Median) String 

func (m *Decimal128Median) String() string

func (*Decimal128Median) Unmarshal 

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

func (*Decimal128Median) XXX_DiscardUnknown 

func (m *Decimal128Median) XXX_DiscardUnknown()

func (*Decimal128Median) XXX_Marshal 

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

func (*Decimal128Median) XXX_Merge 

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

func (*Decimal128Median) XXX_Size 

func (m *Decimal128Median) XXX_Size() int

func (*Decimal128Median) XXX_Unmarshal 

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

type Decimal128SlicePB 

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

func (*Decimal128SlicePB) Descriptor 

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

func (*Decimal128SlicePB) Marshal 

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

func (*Decimal128SlicePB) MarshalTo 

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

func (*Decimal128SlicePB) MarshalToSizedBuffer 

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

func (*Decimal128SlicePB) ProtoMessage 

func (*Decimal128SlicePB) ProtoMessage()

func (*Decimal128SlicePB) ProtoSize 

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

func (*Decimal128SlicePB) Reset 

func (m *Decimal128SlicePB) Reset()

func (*Decimal128SlicePB) String 

func (m *Decimal128SlicePB) String() string

func (*Decimal128SlicePB) Unmarshal 

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

func (*Decimal128SlicePB) XXX_DiscardUnknown 

func (m *Decimal128SlicePB) XXX_DiscardUnknown()

func (*Decimal128SlicePB) XXX_Marshal 

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

func (*Decimal128SlicePB) XXX_Merge 

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

func (*Decimal128SlicePB) XXX_Size 

func (m *Decimal128SlicePB) XXX_Size() int

func (*Decimal128SlicePB) XXX_Unmarshal 

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

type Decimal64Median 

type Decimal64Median struct {
	Vals []decimal64Slice `protobuf:"bytes,1,rep,name=Vals,proto3,customtype=decimal64Slice" json:"Vals"`
}

func (*Decimal64Median) Descriptor 

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

func (*Decimal64Median) Marshal 

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

func (*Decimal64Median) MarshalTo 

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

func (*Decimal64Median) MarshalToSizedBuffer 

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

func (*Decimal64Median) ProtoMessage 

func (*Decimal64Median) ProtoMessage()

func (*Decimal64Median) ProtoSize 

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

func (*Decimal64Median) Reset 

func (m *Decimal64Median) Reset()

func (*Decimal64Median) String 

func (m *Decimal64Median) String() string

func (*Decimal64Median) Unmarshal 

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

func (*Decimal64Median) XXX_DiscardUnknown 

func (m *Decimal64Median) XXX_DiscardUnknown()

func (*Decimal64Median) XXX_Marshal 

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

func (*Decimal64Median) XXX_Merge 

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

func (*Decimal64Median) XXX_Size 

func (m *Decimal64Median) XXX_Size() int

func (*Decimal64Median) XXX_Unmarshal 

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

type Decimal64SlicePB 

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

func (*Decimal64SlicePB) Descriptor 

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

func (*Decimal64SlicePB) Marshal 

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

func (*Decimal64SlicePB) MarshalTo 

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

func (*Decimal64SlicePB) MarshalToSizedBuffer 

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

func (*Decimal64SlicePB) ProtoMessage 

func (*Decimal64SlicePB) ProtoMessage()

func (*Decimal64SlicePB) ProtoSize 

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

func (*Decimal64SlicePB) Reset 

func (m *Decimal64SlicePB) Reset()

func (*Decimal64SlicePB) String 

func (m *Decimal64SlicePB) String() string

func (*Decimal64SlicePB) Unmarshal 

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

func (*Decimal64SlicePB) XXX_DiscardUnknown 

func (m *Decimal64SlicePB) XXX_DiscardUnknown()

func (*Decimal64SlicePB) XXX_Marshal 

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

func (*Decimal64SlicePB) XXX_Merge 

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

func (*Decimal64SlicePB) XXX_Size 

func (m *Decimal64SlicePB) XXX_Size() int

func (*Decimal64SlicePB) XXX_Unmarshal 

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

type EncodeDecimalV 

type EncodeDecimalV struct {
	Sum    []github_com_matrixorigin_matrixone_pkg_container_types.Decimal128 `` /* 135-byte string literal not displayed */
	Counts []int64                                                            `protobuf:"varint,2,rep,packed,name=Counts,proto3" json:"Counts,omitempty"`
	ErrOne []bool                                                             `protobuf:"varint,3,rep,packed,name=ErrOne,proto3" json:"ErrOne,omitempty"`
}

func (*EncodeDecimalV) Descriptor 

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

func (*EncodeDecimalV) GetCounts 

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

func (*EncodeDecimalV) GetErrOne 

func (m *EncodeDecimalV) GetErrOne() []bool

func (*EncodeDecimalV) Marshal 

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

func (*EncodeDecimalV) MarshalTo 

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

func (*EncodeDecimalV) MarshalToSizedBuffer 

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

func (*EncodeDecimalV) ProtoMessage 

func (*EncodeDecimalV) ProtoMessage()

func (*EncodeDecimalV) ProtoSize 

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

func (*EncodeDecimalV) Reset 

func (m *EncodeDecimalV) Reset()

func (*EncodeDecimalV) String 

func (m *EncodeDecimalV) String() string

func (*EncodeDecimalV) Unmarshal 

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

func (*EncodeDecimalV) XXX_DiscardUnknown 

func (m *EncodeDecimalV) XXX_DiscardUnknown()

func (*EncodeDecimalV) XXX_Marshal 

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

func (*EncodeDecimalV) XXX_Merge 

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

func (*EncodeDecimalV) XXX_Size 

func (m *EncodeDecimalV) XXX_Size() int

func (*EncodeDecimalV) XXX_Unmarshal 

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

type EncodeVariance 

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

func (*EncodeVariance) Descriptor 

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

func (*EncodeVariance) GetCounts 

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

func (*EncodeVariance) GetSum 

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

func (*EncodeVariance) Marshal 

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

func (*EncodeVariance) MarshalTo 

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

func (*EncodeVariance) MarshalToSizedBuffer 

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

func (*EncodeVariance) ProtoMessage 

func (*EncodeVariance) ProtoMessage()

func (*EncodeVariance) ProtoSize 

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

func (*EncodeVariance) Reset 

func (m *EncodeVariance) Reset()

func (*EncodeVariance) String 

func (m *EncodeVariance) String() string

func (*EncodeVariance) Unmarshal 

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

func (*EncodeVariance) XXX_DiscardUnknown 

func (m *EncodeVariance) XXX_DiscardUnknown()

func (*EncodeVariance) XXX_Marshal 

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

func (*EncodeVariance) XXX_Merge 

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

func (*EncodeVariance) XXX_Size 

func (m *EncodeVariance) XXX_Size() int

func (*EncodeVariance) XXX_Unmarshal 

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

type NumericMedian 

type NumericMedian[T numeric] struct {
	Vals []numericSlice[T]
}

type VarianceDecimal 

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

	// ErrOne indicates that there is only one row in the group.
	// but its ^2 is too large.
	ErrOne []bool
	// contains filtered or unexported fields
}

func (*VarianceDecimal) Descriptor 

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

func (*VarianceDecimal) Dup added in v1.1.0 

func (s *VarianceDecimal) Dup() agg.AggStruct

func (*VarianceDecimal) Eval 

func (s *VarianceDecimal) Eval(lastResult []types.Decimal128) ([]types.Decimal128, error)

func (*VarianceDecimal) EvalStdDevPop 

func (s *VarianceDecimal) EvalStdDevPop(lastResult []types.Decimal128) ([]types.Decimal128, error)

func (*VarianceDecimal) FillD128 

func (s *VarianceDecimal) FillD128(groupNumber int64, v types.Decimal128, lastResult types.Decimal128, count int64, isEmpty bool, isNull bool) (types.Decimal128, bool, error)

func (*VarianceDecimal) FillD64 

func (s *VarianceDecimal) FillD64(groupNumber int64, v types.Decimal64, lastResult types.Decimal128, count int64, isEmpty bool, isNull bool) (types.Decimal128, bool, error)

func (*VarianceDecimal) Free 

func (s *VarianceDecimal) Free(_ *mpool.MPool)

func (*VarianceDecimal) GetCounts 

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

func (*VarianceDecimal) GetErrOne 

func (m *VarianceDecimal) GetErrOne() []bool

func (*VarianceDecimal) GetScaleDiv 

func (m *VarianceDecimal) GetScaleDiv() int32

func (*VarianceDecimal) GetScaleDivMul 

func (m *VarianceDecimal) GetScaleDivMul() int32

func (*VarianceDecimal) GetScaleMul 

func (m *VarianceDecimal) GetScaleMul() int32

func (*VarianceDecimal) GetScaleMulDiv 

func (m *VarianceDecimal) GetScaleMulDiv() int32

func (*VarianceDecimal) Grows 

func (s *VarianceDecimal) Grows(cnt int)

func (*VarianceDecimal) Marshal 

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

func (*VarianceDecimal) MarshalBinary 

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

func (*VarianceDecimal) MarshalTo 

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

func (*VarianceDecimal) MarshalToSizedBuffer 

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

func (*VarianceDecimal) Merge 

func (s *VarianceDecimal) Merge(groupNumber1 int64, groupNumber2 int64, result1 types.Decimal128, result2 types.Decimal128, isEmpty1 bool, isEmpty2 bool, priv2 any) (types.Decimal128, bool, error)

func (*VarianceDecimal) ProtoMessage 

func (*VarianceDecimal) ProtoMessage()

func (*VarianceDecimal) ProtoSize 

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

func (*VarianceDecimal) Reset 

func (m *VarianceDecimal) Reset()

func (*VarianceDecimal) String 

func (m *VarianceDecimal) String() string

func (*VarianceDecimal) Unmarshal 

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

func (*VarianceDecimal) UnmarshalBinary 

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

func (*VarianceDecimal) XXX_DiscardUnknown 

func (m *VarianceDecimal) XXX_DiscardUnknown()

func (*VarianceDecimal) XXX_Marshal 

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

func (*VarianceDecimal) XXX_Merge 

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

func (*VarianceDecimal) XXX_Size 

func (m *VarianceDecimal) XXX_Size() int

func (*VarianceDecimal) XXX_Unmarshal 

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

type VariancePB 

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 

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

func (*VariancePB) GetCounts 

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

func (*VariancePB) GetSum 

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

func (*VariancePB) Marshal 

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

func (*VariancePB) MarshalTo 

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

func (*VariancePB) MarshalToSizedBuffer 

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

func (*VariancePB) ProtoMessage 

func (*VariancePB) ProtoMessage()

func (*VariancePB) ProtoSize 

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

func (*VariancePB) Reset 

func (m *VariancePB) Reset()

func (*VariancePB) String 

func (m *VariancePB) String() string

func (*VariancePB) Unmarshal 

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

func (*VariancePB) XXX_DiscardUnknown 

func (m *VariancePB) XXX_DiscardUnknown()

func (*VariancePB) XXX_Marshal 

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

func (*VariancePB) XXX_Merge 

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

func (*VariancePB) XXX_Size 

func (m *VariancePB) XXX_Size() int

func (*VariancePB) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis
algos
kmeans
kmeans/elkans

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.