Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getFunctionName (0.08 sec)

  1. internal/s3select/sql/aggregation.go

    func (e *FuncExpr) evalAggregationNode(r Record, tableAlias string) error {
    	// It is assumed that this function is called only when
    	// `e` is an aggregation function.
    
    	var val *Value
    	var err error
    	funcName := e.getFunctionName()
    	if aggFnCount == funcName {
    		if e.Count.StarArg {
    			// Handle COUNT(*)
    			e.aggregate.runningCount++
    			return nil
    		}
    
    		val, err = e.Count.ExprArg.evalNode(r, tableAlias)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. internal/s3select/sql/analysis.go

    		result = e.FuncCall.analyze(s)
    
    	default:
    		result = qProp{err: errUnexpectedInvalidNode}
    	}
    	return
    }
    
    func (e *FuncExpr) analyze(s *Select) (result qProp) {
    	funcName := e.getFunctionName()
    
    	switch funcName {
    	case sqlFnCast:
    		return e.Cast.Expr.analyze(s)
    
    	case sqlFnExtract:
    		return e.Extract.From.analyze(s)
    
    	case sqlFnDateAdd:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  3. internal/s3select/sql/evaluate.go

    	case e.FuncCall != nil:
    		return e.FuncCall.evalNode(r, tableAlias)
    	}
    	return nil, errInvalidASTNode
    }
    
    func (e *FuncExpr) evalNode(r Record, tableAlias string) (res *Value, err error) {
    	switch e.getFunctionName() {
    	case aggFnCount, aggFnAvg, aggFnMax, aggFnMin, aggFnSum:
    		return e.getAggregate()
    	default:
    		return e.evalSQLFnNode(r, tableAlias)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
Back to top