Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newAggVal (0.06 sec)

  1. internal/s3select/sql/analysis.go

    		result.combine(e.DateDiff.Timestamp2.analyze(s))
    		return result
    
    	// Handle aggregation function calls
    	case aggFnAvg, aggFnMax, aggFnMin, aggFnSum, aggFnCount:
    		// Initialize accumulator
    		e.aggregate = newAggVal(funcName)
    
    		var exprA qProp
    		if funcName == aggFnCount {
    			if e.Count.StarArg {
    				return qProp{isAggregation: true}
    			}
    
    			exprA = e.Count.ExprArg.analyze(s)
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  2. internal/s3select/sql/aggregation.go

    )
    
    type aggVal struct {
    	runningSum             *Value
    	runningCount           int64
    	runningMax, runningMin *Value
    
    	// Stores if at least one record has been seen
    	seen bool
    }
    
    func newAggVal(fn FuncName) *aggVal {
    	switch fn {
    	case aggFnAvg, aggFnSum:
    		return &aggVal{runningSum: FromFloat(0)}
    	case aggFnMin:
    		return &aggVal{runningMin: FromInt(0)}
    	case aggFnMax:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 7.9K bytes
    - Viewed (0)
Back to top