expression

Documentation

Index

• Constants
• func GetResults(aggrs []*Aggregation, evalCtxs []*AggEvaluateContext, x []sqltypes.Value) ([]sqltypes.Value, []int)
• type AggEvaluateContext
  • func NewAggEvalCtxs(aggrs []*Aggregation, x []sqltypes.Value) []*AggEvaluateContext
• type Aggregation
  • func NewAggregations(plans []planner.Aggregator, isPushDown bool, fields []*querypb.Field) []*Aggregation
  • func (aggr *Aggregation) FixField(field *querypb.Field)
  • func (aggr *Aggregation) GetResult(evalCtx *AggEvaluateContext) sqltypes.Value
  • func (aggr *Aggregation) InitEvalCtx(x []sqltypes.Value) *AggEvaluateContext
  • func (aggr *Aggregation) Update(x []sqltypes.Value, evalCtx *AggEvaluateContext)

Constants

const (
	// DecimalLongLongDigits decimal longlong digits.
	DecimalLongLongDigits = 22
	// FloatDigits float decimal precision.
	FloatDigits = 6
	// DoubleDigits double decimal precision.
	DoubleDigits = 15
)

Functions

func GetResults

func GetResults(aggrs []*Aggregation, evalCtxs []*AggEvaluateContext, x []sqltypes.Value) ([]sqltypes.Value, []int)

GetResults will be called when all data have been processed.

Types

type AggEvaluateContext

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

AggEvaluateContext is used to store intermediate result when calculating aggregate functions.

func NewAggEvalCtxs

func NewAggEvalCtxs(aggrs []*Aggregation, x []sqltypes.Value) []*AggEvaluateContext

NewAggEvalCtxs new evalCtxs.

type Aggregation

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

Aggregation operator.

func NewAggregations

func NewAggregations(plans []planner.Aggregator, isPushDown bool, fields []*querypb.Field) []*Aggregation

NewAggregations new aggrs based on plans.

func (*Aggregation) FixField

func (aggr *Aggregation) FixField(field *querypb.Field)

FixField used to fix querypb.Field lenght and decimal.

func (*Aggregation) GetResult

func (aggr *Aggregation) GetResult(evalCtx *AggEvaluateContext) sqltypes.Value

GetResult used to get Value finally.

func (*Aggregation) InitEvalCtx

func (aggr *Aggregation) InitEvalCtx(x []sqltypes.Value) *AggEvaluateContext

InitEvalCtx used to init the AggEvaluateContext.

func (*Aggregation) Update

func (aggr *Aggregation) Update(x []sqltypes.Value, evalCtx *AggEvaluateContext)

Update during executing.