Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for getFunctionName (0.2 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  2. internal/s3select/sql/funceval.go

    	errNonStringTrimArg  = errors.New("TRIM() received a non-string argument")
    	errNonTimestampArg   = errors.New("Expected a timestamp argument")
    )
    
    func (e *FuncExpr) getFunctionName() FuncName {
    	switch {
    	case e.SFunc != nil:
    		return FuncName(strings.ToUpper(e.SFunc.FunctionName))
    	case e.Count != nil:
    		return aggFnCount
    	case e.Cast != nil:
    		return sqlFnCast
    	case e.Substring != nil:
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 13.2K 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)
    	}
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 12K bytes
    - Viewed (0)
  4. 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:
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 8.5K bytes
    - Viewed (0)
Back to top