Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

functionAgg

package

Go to main page

Versions in this module

v1

v1.1.3

Apr 15, 2024

v1.1.2

Apr 2, 2024

v1.1.1

Feb 2, 2024

v1.1.0

Dec 29, 2023

Changes in this version

+ var AggClusterCentersReturnType = func(typs []types.Type) types.Type

+ var AggClusterCentersSupportedParameters = []types.T

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

type VarianceDecimal

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

v1.0.2

Dec 21, 2023

v1.0.1

Dec 15, 2023

v1.0.0

Nov 13, 2023

Changes in this version

+ var AggAnyValueReturnType = func(typs []types.Type) types.Type

+ var AggAnyValueSupportedParameters = []types.T

+ var AggApproxCountReturnType = func(typs []types.Type) types.Type

+ var AggAvgReturnType = func(typs []types.Type) types.Type

+ var AggAvgSupportedParameters = []types.T

+ var AggBitAndReturnType = func(typs []types.Type) types.Type

+ var AggBitAndSupportedParameters = []types.T

+ var AggBitOrReturnType = AggBitAndReturnType

+ var AggBitOrSupportedParameters = []types.T

+ var AggBitXorReturnType = AggBitAndReturnType

+ var AggBitXorSupportedParameters = []types.T

+ var AggCountReturnType = func(typs []types.Type) types.Type

+ var AggGroupConcatReturnType = func(typs []types.Type) types.Type

+ var AggMaxReturnType = func(typs []types.Type) types.Type

+ var AggMaxSupportedParameters = []types.T

+ var AggMedianReturnType = func(typs []types.Type) types.Type

+ var AggMedianSupportedParameters = []types.T

+ var AggMinSupportedParameters = []types.T

+ var AggMinxReturnType = func(typs []types.Type) types.Type

+ var AggStdDevReturnType = AggVarianceReturnType

+ var AggStdDevSupportedParameters = []types.T

+ var AggSumReturnType = func(typs []types.Type) types.Type

+ var AggSumSupportedParameters = []types.T

+ var AggVarianceReturnType = func(typs []types.Type) types.Type

+ var AggVarianceSupportedParameters = []types.T

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

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

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

+ var WinDenseRankReturnType = func(typs []types.Type) types.Type

+ var WinRankReturnType = func(typs []types.Type) types.Type

+ var WinRowNumberReturnType = func(typs []types.Type) types.Type

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type Decimal128Median struct

+ Vals []decimal128Slice

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

+ func (*Decimal128Median) ProtoMessage()

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

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

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

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

+ func (m *Decimal128Median) Reset()

+ func (m *Decimal128Median) String() string

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

+ func (m *Decimal128Median) XXX_DiscardUnknown()

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

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

+ func (m *Decimal128Median) XXX_Size() int

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

+ type Decimal128SlicePB struct

+ Slice []github_com_matrixorigin_matrixone_pkg_container_types.Decimal128

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

+ func (*Decimal128SlicePB) ProtoMessage()

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

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

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

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

+ func (m *Decimal128SlicePB) Reset()

+ func (m *Decimal128SlicePB) String() string

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

+ func (m *Decimal128SlicePB) XXX_DiscardUnknown()

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

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

+ func (m *Decimal128SlicePB) XXX_Size() int

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

+ type Decimal64Median struct

+ Vals []decimal64Slice

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

+ func (*Decimal64Median) ProtoMessage()

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

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

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

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

+ func (m *Decimal64Median) Reset()

+ func (m *Decimal64Median) String() string

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

+ func (m *Decimal64Median) XXX_DiscardUnknown()

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

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

+ func (m *Decimal64Median) XXX_Size() int

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

+ type Decimal64SlicePB struct

+ Slice []github_com_matrixorigin_matrixone_pkg_container_types.Decimal64

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

+ func (*Decimal64SlicePB) ProtoMessage()

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

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

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

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

+ func (m *Decimal64SlicePB) Reset()

+ func (m *Decimal64SlicePB) String() string

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

+ func (m *Decimal64SlicePB) XXX_DiscardUnknown()

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

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

+ func (m *Decimal64SlicePB) XXX_Size() int

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

+ type EncodeDecimalV struct

+ Counts []int64

+ ErrOne []bool

+ Sum []github_com_matrixorigin_matrixone_pkg_container_types.Decimal128

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

+ func (*EncodeDecimalV) ProtoMessage()

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

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

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

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

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

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

+ func (m *EncodeDecimalV) Reset()

+ func (m *EncodeDecimalV) String() string

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

+ func (m *EncodeDecimalV) XXX_DiscardUnknown()

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

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

+ func (m *EncodeDecimalV) XXX_Size() int

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

+ type EncodeVariance struct

+ Counts []float64

+ Sum []float64

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

+ func (*EncodeVariance) ProtoMessage()

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

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

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

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

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

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

+ func (m *EncodeVariance) Reset()

+ func (m *EncodeVariance) String() string

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

+ func (m *EncodeVariance) XXX_DiscardUnknown()

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

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

+ func (m *EncodeVariance) XXX_Size() int

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

+ type NumericMedian struct

+ Vals []numericSlice[T]

+ type VarianceDecimal struct

+ Counts []int64

+ ErrOne []bool

+ ScaleDiv int32

+ ScaleDivMul int32

+ ScaleMul int32

+ ScaleMulDiv int32

+ Sum []types.Decimal128

+ Typ types.Type

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

+ func (*VarianceDecimal) ProtoMessage()

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

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

+ func (m *VarianceDecimal) GetScaleDiv() int32

+ func (m *VarianceDecimal) GetScaleDivMul() int32

+ func (m *VarianceDecimal) GetScaleMul() int32

+ func (m *VarianceDecimal) GetScaleMulDiv() int32

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

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

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

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

+ func (m *VarianceDecimal) Reset()

+ func (m *VarianceDecimal) String() string

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

+ func (m *VarianceDecimal) XXX_DiscardUnknown()

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

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

+ func (m *VarianceDecimal) XXX_Size() int

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

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

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

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

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

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

+ func (s *VarianceDecimal) Grows(cnt int)

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

+ func (s *VarianceDecimal) Merge(groupNumber1 int64, groupNumber2 int64, result1 types.Decimal128, ...) (types.Decimal128, bool, error)

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

+ type VariancePB struct

+ Counts []float64

+ Sum []float64

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

+ func (*VariancePB) ProtoMessage()

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

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

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

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

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

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

+ func (m *VariancePB) Reset()

+ func (m *VariancePB) String() string

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

+ func (m *VariancePB) XXX_DiscardUnknown()

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

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

+ func (m *VariancePB) XXX_Size() int

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

v1.0.0-rc2

Oct 24, 2023