agg

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: May 17, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SumSupportedTypes = []types.T{
		types.T_bit,
		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,
	}
	SumReturnType = 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_bit:
			return types.T_uint64.ToType()
		case types.T_decimal64:
			return types.New(types.T_decimal128, 38, 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 AnyValueSupportedTypes = []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_bit,
	types.T_varchar, types.T_char, types.T_blob, types.T_text,
	types.T_uuid,
	types.T_binary, types.T_varbinary,
	types.T_Rowid,
}
View Source 
var AvgSupportedTypes = []types.T{
	types.T_bit,
	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 BitAndSupportedParameters = []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,
	types.T_bit,
}
View Source 
var BitOrReturnType = BitAndReturnType
View Source 
var BitXorReturnType = BitAndReturnType
View Source 
var BitmapConstructSupportedTypes = []types.T{
	types.T_uint64,
}
View Source 
var BitmapOrReturnType = BitmapConstructReturnType
View Source 
var BitmapOrSupportedTypes = []types.T{
	types.T_varbinary,
}
View Source 
var MaxSupportedTypes = []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_bit,
	types.T_varchar, types.T_char, types.T_blob, types.T_text,
	types.T_uuid,
	types.T_binary, types.T_varbinary,
}
View Source 
var MinSupportedTypes = []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_bit,
	types.T_varchar, types.T_char, types.T_blob, types.T_text,
	types.T_uuid,
	types.T_binary, types.T_varbinary,
}
View Source 
var VarPopSupportedParameters = []types.T{
	types.T_bit,
	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 

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

func AvgReturnType 

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

func BitAndReturnType 

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

func BitmapConstructReturnType 

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

func FillAggAvg1 

func FillAggAvg1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, float64], value from, getter aggexec.AggGetter[float64], setter aggexec.AggSetter[float64]) error

func FillAggAvgDecimal128 

func FillAggAvgDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], value types.Decimal128, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillAggAvgDecimal64 

func FillAggAvgDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128], value types.Decimal64, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillAggBitAnd1 

func FillAggBitAnd1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, uint64], value from, getter aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func FillAggBitAndBinary 

func FillAggBitAndBinary(
	exec aggexec.SingleAggFromVarRetVar, value []byte, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillAggBitOr1 

func FillAggBitOr1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, uint64], value from, getter aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func FillAggBitOrBinary 

func FillAggBitOrBinary(
	exec aggexec.SingleAggFromVarRetVar, value []byte, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillAggBitXor1 

func FillAggBitXor1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, uint64], value from, getter aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func FillAggBitXorBinary 

func FillAggBitXorBinary(
	exec aggexec.SingleAggFromVarRetVar, value []byte, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillAggBitmapConstruct 

func FillAggBitmapConstruct(
	exec aggexec.SingleAggFromFixedRetVar[uint64],
	value uint64, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillAggBitmapOr 

func FillAggBitmapOr(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillAggMax1 

func FillAggMax1[from canCompare](
	exec aggexec.SingleAggFromFixedRetFixed[from, from],
	value from, getter aggexec.AggGetter[from], setter aggexec.AggSetter[from]) error

func FillAggMaxBool 

func FillAggMaxBool(
	exec aggexec.SingleAggFromFixedRetFixed[bool, bool],
	value bool, getter aggexec.AggGetter[bool], setter aggexec.AggSetter[bool]) error

func FillAggMaxBytes 

func FillAggMaxBytes(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillAggMaxDecimal128 

func FillAggMaxDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	value types.Decimal128, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillAggMaxDecimal64 

func FillAggMaxDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal64],
	value types.Decimal64, getter aggexec.AggGetter[types.Decimal64], setter aggexec.AggSetter[types.Decimal64]) error

func FillAggMaxUuid 

func FillAggMaxUuid(
	exec aggexec.SingleAggFromFixedRetFixed[types.Uuid, types.Uuid],
	value types.Uuid, getter aggexec.AggGetter[types.Uuid], setter aggexec.AggSetter[types.Uuid]) error

func FillAggMin1 

func FillAggMin1[from canCompare](
	exec aggexec.SingleAggFromFixedRetFixed[from, from],
	value from, getter aggexec.AggGetter[from], setter aggexec.AggSetter[from]) error

func FillAggMinBool 

func FillAggMinBool(
	exec aggexec.SingleAggFromFixedRetFixed[bool, bool],
	value bool, getter aggexec.AggGetter[bool], setter aggexec.AggSetter[bool]) error

func FillAggMinBytes 

func FillAggMinBytes(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillAggMinDecimal128 

func FillAggMinDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	value types.Decimal128, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillAggMinDecimal64 

func FillAggMinDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal64],
	value types.Decimal64, getter aggexec.AggGetter[types.Decimal64], setter aggexec.AggSetter[types.Decimal64]) error

func FillAggMinUuid 

func FillAggMinUuid(
	exec aggexec.SingleAggFromFixedRetFixed[types.Uuid, types.Uuid],
	value types.Uuid, getter aggexec.AggGetter[types.Uuid], setter aggexec.AggSetter[types.Uuid]) error

func FillAggSum1 

func FillAggSum1[from numeric, to numericWithMaxScale](
	exec aggexec.SingleAggFromFixedRetFixed[from, to], value from, getter aggexec.AggGetter[to], setter aggexec.AggSetter[to]) error

func FillAggSumDecimal128 

func FillAggSumDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], value types.Decimal128, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillAggSumDecimal64 

func FillAggSumDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128], value types.Decimal64, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillAggVarPop1 

func FillAggVarPop1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, float64],
	value from, getter aggexec.AggGetter[float64], setter aggexec.AggSetter[float64]) error

func FillAggVarPop1Decimal128 

func FillAggVarPop1Decimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	value types.Decimal128, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillAggVarPop1Decimal64 

func FillAggVarPop1Decimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128],
	value types.Decimal64, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillAnyValue1 

func FillAnyValue1[from types.FixedSizeTExceptStrType](
	exec aggexec.SingleAggFromFixedRetFixed[from, from], value from, getter aggexec.AggGetter[from], setter aggexec.AggSetter[from]) error

func FillAnyValue2 

func FillAnyValue2(
	exec aggexec.SingleAggFromVarRetVar, value []byte, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillsAggAvg1 

func FillsAggAvg1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, float64], value from, isNull bool, count int, getter aggexec.AggGetter[float64], setter aggexec.AggSetter[float64]) error

func FillsAggAvgDecimal128 

func FillsAggAvgDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], value types.Decimal128, isNull bool, count int, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillsAggAvgDecimal64 

func FillsAggAvgDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128], value types.Decimal64, isNull bool, count int, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillsAggBitAnd1 

func FillsAggBitAnd1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, uint64],
	value from, isNull bool, count int, getter aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func FillsAggBitAndBinary 

func FillsAggBitAndBinary(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, isNull bool, count int, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillsAggBitOr1 

func FillsAggBitOr1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, uint64],
	value from, isNull bool, count int, getter aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func FillsAggBitOrBinary 

func FillsAggBitOrBinary(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, isNull bool, count int, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillsAggBitXor1 

func FillsAggBitXor1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, uint64],
	value from, isNull bool, count int, getter aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func FillsAggBitXorBinary 

func FillsAggBitXorBinary(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, isNull bool, count int, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillsAggBitmapConstruct 

func FillsAggBitmapConstruct(
	exec aggexec.SingleAggFromFixedRetVar[uint64],
	value uint64, isNull bool, count int, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillsAggBitmapOr 

func FillsAggBitmapOr(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, isNull bool, count int, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillsAggMax1 

func FillsAggMax1[from canCompare](
	exec aggexec.SingleAggFromFixedRetFixed[from, from],
	value from, isNull bool, count int, getter aggexec.AggGetter[from], setter aggexec.AggSetter[from]) error

func FillsAggMaxBool 

func FillsAggMaxBool(
	exec aggexec.SingleAggFromFixedRetFixed[bool, bool],
	value bool, isNull bool, count int, getter aggexec.AggGetter[bool], setter aggexec.AggSetter[bool]) error

func FillsAggMaxBytes 

func FillsAggMaxBytes(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, isNull bool, count int, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillsAggMaxDecimal128 

func FillsAggMaxDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	value types.Decimal128, isNull bool, count int, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillsAggMaxDecimal64 

func FillsAggMaxDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal64],
	value types.Decimal64, isNull bool, count int, getter aggexec.AggGetter[types.Decimal64], setter aggexec.AggSetter[types.Decimal64]) error

func FillsAggMaxUuid 

func FillsAggMaxUuid(
	exec aggexec.SingleAggFromFixedRetFixed[types.Uuid, types.Uuid],
	value types.Uuid, isNull bool, count int, getter aggexec.AggGetter[types.Uuid], setter aggexec.AggSetter[types.Uuid]) error

func FillsAggMin1 

func FillsAggMin1[from canCompare](
	exec aggexec.SingleAggFromFixedRetFixed[from, from],
	value from, isNull bool, count int, getter aggexec.AggGetter[from], setter aggexec.AggSetter[from]) error

func FillsAggMinBool 

func FillsAggMinBool(
	exec aggexec.SingleAggFromFixedRetFixed[bool, bool],
	value bool, isNull bool, count int, getter aggexec.AggGetter[bool], setter aggexec.AggSetter[bool]) error

func FillsAggMinBytes 

func FillsAggMinBytes(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, isNull bool, count int, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FillsAggMinDecimal128 

func FillsAggMinDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	value types.Decimal128, isNull bool, count int, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillsAggMinDecimal64 

func FillsAggMinDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal64],
	value types.Decimal64, isNull bool, count int, getter aggexec.AggGetter[types.Decimal64], setter aggexec.AggSetter[types.Decimal64]) error

func FillsAggMinUuid 

func FillsAggMinUuid(
	exec aggexec.SingleAggFromFixedRetFixed[types.Uuid, types.Uuid],
	value types.Uuid, isNull bool, count int, getter aggexec.AggGetter[types.Uuid], setter aggexec.AggSetter[types.Uuid]) error

func FillsAggSum1 

func FillsAggSum1[from numeric, to numericWithMaxScale](
	exec aggexec.SingleAggFromFixedRetFixed[from, to],
	value from, isNull bool, count int, getter aggexec.AggGetter[to], setter aggexec.AggSetter[to]) error

func FillsAggSumDecimal128 

func FillsAggSumDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	value types.Decimal128, isNull bool, count int, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillsAggSumDecimal64 

func FillsAggSumDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128],
	value types.Decimal64, isNull bool, count int, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillsAggVarPop1 

func FillsAggVarPop1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, float64],
	value from, isNull bool, count int, getter aggexec.AggGetter[float64], setter aggexec.AggSetter[float64]) error

func FillsAggVarPop1Decimal128 

func FillsAggVarPop1Decimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	value types.Decimal128, isNull bool, count int, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillsAggVarPop1Decimal64 

func FillsAggVarPop1Decimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128],
	value types.Decimal64, isNull bool, count int, getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FillsAnyValue1 

func FillsAnyValue1[from types.FixedSizeTExceptStrType](
	exec aggexec.SingleAggFromFixedRetFixed[from, from],
	value from, isNull bool, count int, getter aggexec.AggGetter[from], setter aggexec.AggSetter[from]) error

func FillsAnyValue2 

func FillsAnyValue2(
	exec aggexec.SingleAggFromVarRetVar,
	value []byte, isNull bool, count int, getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FlushAggAvg1 

func FlushAggAvg1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, float64], getter aggexec.AggGetter[float64], setter aggexec.AggSetter[float64]) error

func FlushAggAvgDecimal128 

func FlushAggAvgDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FlushAggAvgDecimal64 

func FlushAggAvgDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128], getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FlushAggBitmapConstruct 

func FlushAggBitmapConstruct(
	exec aggexec.SingleAggFromFixedRetVar[uint64],
	getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FlushAggBitmapOr 

func FlushAggBitmapOr(
	exec aggexec.SingleAggFromVarRetVar,
	getter aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func FlushAggStdDevPop1 

func FlushAggStdDevPop1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, float64],
	getter aggexec.AggGetter[float64], setter aggexec.AggSetter[float64]) error

func FlushAggStdDevPopDecimal128 

func FlushAggStdDevPopDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FlushAggStdDevPopDecimal64 

func FlushAggStdDevPopDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128],
	getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FlushAggVarPop1 

func FlushAggVarPop1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, float64],
	getter aggexec.AggGetter[float64], setter aggexec.AggSetter[float64]) error

func FlushAggVarPop1Decimal128 

func FlushAggVarPop1Decimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func FlushAggVarPop1Decimal64 

func FlushAggVarPop1Decimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128],
	getter aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func InitAggAvg1 

func InitAggAvg1[from numeric](exec aggexec.SingleAggFromFixedRetFixed[from, float64], set aggexec.AggSetter[float64], arg, ret types.Type) error

func InitAggAvgDecimal128 

func InitAggAvgDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], set aggexec.AggSetter[types.Decimal128], arg, ret types.Type) error

func InitAggAvgDecimal64 

func InitAggAvgDecimal64(exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128], set aggexec.AggSetter[types.Decimal128], arg, ret types.Type) error

func InitAggBitAnd1 

func InitAggBitAnd1[T numeric](exec aggexec.SingleAggFromFixedRetFixed[T, uint64], set aggexec.AggSetter[uint64], arg types.Type, ret types.Type) error

func InitAggBitOr1 

func InitAggBitOr1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, uint64], setter aggexec.AggSetter[uint64], arg, ret types.Type) error

func InitAggBitXor 

func InitAggBitXor[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, uint64], setter aggexec.AggSetter[uint64], arg, ret types.Type) error

func InitAggBitmapConstruct 

func InitAggBitmapConstruct(
	exec aggexec.SingleAggFromFixedRetVar[uint64], set aggexec.AggBytesSetter, arg, ret types.Type) error

func InitAggBitmapOr 

func InitAggBitmapOr(
	exec aggexec.SingleAggFromVarRetVar, set aggexec.AggBytesSetter, arg, ret types.Type) error

func InitAggMax1 

func InitAggMax1[from canCompare](
	exec aggexec.SingleAggFromFixedRetFixed[from, from], setter aggexec.AggSetter[from], arg, ret types.Type) error

func InitAggMaxBool 

func InitAggMaxBool(exec aggexec.SingleAggFromFixedRetFixed[bool, bool], setter aggexec.AggSetter[bool], arg, ret types.Type) error

func InitAggMaxDecimal128 

func InitAggMaxDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], setter aggexec.AggSetter[types.Decimal128], arg, ret types.Type) error

func InitAggMaxDecimal64 

func InitAggMaxDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal64], setter aggexec.AggSetter[types.Decimal64], arg, ret types.Type) error

func InitAggMin1 

func InitAggMin1[from canCompare](
	exec aggexec.SingleAggFromFixedRetFixed[from, from], setter aggexec.AggSetter[from], arg, ret types.Type) error

func InitAggMinBool 

func InitAggMinBool(
	exec aggexec.SingleAggFromFixedRetFixed[bool, bool],
	setter aggexec.AggSetter[bool], arg, ret types.Type) error

func InitAggMinDecimal128 

func InitAggMinDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	setter aggexec.AggSetter[types.Decimal128], arg, ret types.Type) error

func InitAggMinDecimal64 

func InitAggMinDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal64],
	setter aggexec.AggSetter[types.Decimal64], arg, ret types.Type) error

func InitAggSumDecimal128 

func InitAggSumDecimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], setter aggexec.AggSetter[types.Decimal128], arg, ret types.Type) error

func InitAggSumDecimal64 

func InitAggSumDecimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128], setter aggexec.AggSetter[types.Decimal128], arg, ret types.Type) error

func InitAggVarPop1 

func InitAggVarPop1[from numeric](
	exec aggexec.SingleAggFromFixedRetFixed[from, float64],
	setter aggexec.AggSetter[float64], arg, ret types.Type) error

func InitAggVarPop1Decimal128 

func InitAggVarPop1Decimal128(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	setter aggexec.AggSetter[types.Decimal128], arg, ret types.Type) error

func InitAggVarPop1Decimal64 

func InitAggVarPop1Decimal64(
	exec aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128],
	setter aggexec.AggSetter[types.Decimal128], arg, ret types.Type) error

func MaxReturnType 

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

func MergeAggAvg1 

func MergeAggAvg1[from numeric](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, float64], getter1, getter2 aggexec.AggGetter[float64], setter aggexec.AggSetter[float64]) error

func MergeAggAvgDecimal128 

func MergeAggAvgDecimal128(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], getter1, getter2 aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func MergeAggAvgDecimal64 

func MergeAggAvgDecimal64(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128], getter1, getter2 aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func MergeAggBitAnd1 

func MergeAggBitAnd1[from numeric](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, uint64],
	getter1, getter2 aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func MergeAggBitAndBinary 

func MergeAggBitAndBinary(
	exec1, exec2 aggexec.SingleAggFromVarRetVar,
	getter1, getter2 aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func MergeAggBitOr1 

func MergeAggBitOr1[from numeric](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, uint64],
	getter1, getter2 aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func MergeAggBitOrBinary 

func MergeAggBitOrBinary(
	exec1, exec2 aggexec.SingleAggFromVarRetVar,
	getter1, getter2 aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func MergeAggBitXor1 

func MergeAggBitXor1[from numeric](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, uint64],
	getter1, getter2 aggexec.AggGetter[uint64], setter aggexec.AggSetter[uint64]) error

func MergeAggBitXorBinary 

func MergeAggBitXorBinary(
	exec1, exec2 aggexec.SingleAggFromVarRetVar,
	getter1, getter2 aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func MergeAggBitmapConstruct 

func MergeAggBitmapConstruct(
	exec1, exec2 aggexec.SingleAggFromFixedRetVar[uint64],
	getter1, getter2 aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func MergeAggBitmapOr 

func MergeAggBitmapOr(
	exec1, exec2 aggexec.SingleAggFromVarRetVar,
	getter1, getter2 aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func MergeAggMax1 

func MergeAggMax1[from canCompare](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, from],
	getter1, getter2 aggexec.AggGetter[from], setter1 aggexec.AggSetter[from]) error

func MergeAggMaxBool 

func MergeAggMaxBool(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[bool, bool],
	getter1, getter2 aggexec.AggGetter[bool], setter1 aggexec.AggSetter[bool]) error

func MergeAggMaxBytes 

func MergeAggMaxBytes(
	exec1, exec2 aggexec.SingleAggFromVarRetVar,
	getter1, getter2 aggexec.AggBytesGetter, setter1 aggexec.AggBytesSetter) error

func MergeAggMaxDecimal128 

func MergeAggMaxDecimal128(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	getter1, getter2 aggexec.AggGetter[types.Decimal128], setter1 aggexec.AggSetter[types.Decimal128]) error

func MergeAggMaxDecimal64 

func MergeAggMaxDecimal64(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal64],
	getter1, getter2 aggexec.AggGetter[types.Decimal64], setter1 aggexec.AggSetter[types.Decimal64]) error

func MergeAggMaxUuid 

func MergeAggMaxUuid(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Uuid, types.Uuid],
	getter1, getter2 aggexec.AggGetter[types.Uuid], setter1 aggexec.AggSetter[types.Uuid]) error

func MergeAggMin1 

func MergeAggMin1[from canCompare](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, from],
	getter1, getter2 aggexec.AggGetter[from], setter1 aggexec.AggSetter[from]) error

func MergeAggMinBool 

func MergeAggMinBool(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[bool, bool],
	getter1, getter2 aggexec.AggGetter[bool], setter1 aggexec.AggSetter[bool]) error

func MergeAggMinBytes 

func MergeAggMinBytes(
	exec1, exec2 aggexec.SingleAggFromVarRetVar,
	getter1, getter2 aggexec.AggBytesGetter, setter1 aggexec.AggBytesSetter) error

func MergeAggMinDecimal128 

func MergeAggMinDecimal128(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	getter1, getter2 aggexec.AggGetter[types.Decimal128], setter1 aggexec.AggSetter[types.Decimal128]) error

func MergeAggMinDecimal64 

func MergeAggMinDecimal64(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal64],
	getter1, getter2 aggexec.AggGetter[types.Decimal64], setter1 aggexec.AggSetter[types.Decimal64]) error

func MergeAggMinUuid 

func MergeAggMinUuid(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Uuid, types.Uuid],
	getter1, getter2 aggexec.AggGetter[types.Uuid], setter1 aggexec.AggSetter[types.Uuid]) error

func MergeAggSum1 

func MergeAggSum1[from numeric, to numericWithMaxScale](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, to], getter1, getter2 aggexec.AggGetter[to], setter aggexec.AggSetter[to]) error

func MergeAggSumDecimal128 

func MergeAggSumDecimal128(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128], getter1, getter2 aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func MergeAggSumDecimal64 

func MergeAggSumDecimal64(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128], getter1, getter2 aggexec.AggGetter[types.Decimal128], setter aggexec.AggSetter[types.Decimal128]) error

func MergeAggVarPop1 

func MergeAggVarPop1[from numeric](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, float64],
	getter1, getter2 aggexec.AggGetter[float64], setter1 aggexec.AggSetter[float64]) error

func MergeAggVarPop1Decimal128 

func MergeAggVarPop1Decimal128(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal128, types.Decimal128],
	getter1, getter2 aggexec.AggGetter[types.Decimal128], setter1 aggexec.AggSetter[types.Decimal128]) error

func MergeAggVarPop1Decimal64 

func MergeAggVarPop1Decimal64(
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[types.Decimal64, types.Decimal128],
	getter1, getter2 aggexec.AggGetter[types.Decimal128], setter1 aggexec.AggSetter[types.Decimal128]) error

func MergeAnyValue1 

func MergeAnyValue1[from types.FixedSizeTExceptStrType](
	exec1, exec2 aggexec.SingleAggFromFixedRetFixed[from, from], getter1, getter2 aggexec.AggGetter[from], setter aggexec.AggSetter[from]) error

func MergeAnyValue2 

func MergeAnyValue2(
	exec1, exec2 aggexec.SingleAggFromVarRetVar, getter1, getter2 aggexec.AggBytesGetter, setter aggexec.AggBytesSetter) error

func MinReturnType 

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

func RegisterAnyValue1 

func RegisterAnyValue1(id int64)

func RegisterApproxCount 

func RegisterApproxCount(id int64)

func RegisterAvg1 

func RegisterAvg1(id int64)

func RegisterBitAnd1 

func RegisterBitAnd1(id int64)

func RegisterBitOr1 

func RegisterBitOr1(id int64)

func RegisterBitXor1 

func RegisterBitXor1(id int64)

func RegisterBitmapConstruct1 

func RegisterBitmapConstruct1(id int64)

func RegisterBitmapOr1 

func RegisterBitmapOr1(id int64)

func RegisterClusterCenters 

func RegisterClusterCenters(id int64)

func RegisterCountColumn 

func RegisterCountColumn(id int64)

func RegisterCountStar 

func RegisterCountStar(id int64)

func RegisterDenseRank 

func RegisterDenseRank(id int64)

func RegisterGroupConcat 

func RegisterGroupConcat(id int64)

func RegisterMax1 

func RegisterMax1(id int64)

func RegisterMedian 

func RegisterMedian(id int64)

func RegisterMin1 

func RegisterMin1(id int64)

func RegisterRank 

func RegisterRank(id int64)

func RegisterRowNumber 

func RegisterRowNumber(id int64)

func RegisterStdDevPop1 

func RegisterStdDevPop1(id int64)

func RegisterSum1 

func RegisterSum1(id int64)

func RegisterVarPop1 

func RegisterVarPop1(id int64)

func VarPopReturnType 

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

Types

This section is empty.

Source Files

View all Source files

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.