Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for FromNull (0.28 sec)

  1. internal/s3select/sql/aggregation.go

    	case aggFnAvg:
    		if e.aggregate.runningCount == 0 {
    			// No rows were seen by AVG.
    			return FromNull(), nil
    		}
    		err := e.aggregate.runningSum.arithOp(opDivide, FromInt(e.aggregate.runningCount))
    		return e.aggregate.runningSum, err
    
    	case aggFnMin:
    		if !e.aggregate.seen {
    			// No rows were seen by MIN
    			return FromNull(), nil
    		}
    		return e.aggregate.runningMin, nil
    
    	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)
  2. internal/s3select/csv/record.go

    				// If field index > number of columns, return null
    				return sql.FromNull(), nil
    			}
    			return sql.FromBytes([]byte(r.csvRecord[idx])), nil
    		}
    		// TODO: Return Missing?
    		return nil, fmt.Errorf("column %v not found", name)
    	}
    
    	if index >= int64(len(r.csvRecord)) {
    		// No value found for column 'name', hence return null
    		// value
    		return sql.FromNull(), nil
    	}
    
    	return sql.FromBytes([]byte(r.csvRecord[index])), nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  3. internal/s3select/simdj/record.go

    		}
    		return sql.FromInt(v), nil
    	case simdjson.TypeBool:
    		v, err := iter.Bool()
    		if err != nil {
    			return nil, err
    		}
    		return sql.FromBool(v), nil
    	case simdjson.TypeNull:
    		return sql.FromNull(), nil
    	case simdjson.TypeObject, simdjson.TypeArray:
    		b, err := iter.MarshalJSON()
    		return sql.FromBytes(b), err
    	}
    	return nil, fmt.Errorf("iterToValue: unknown JSON type: %s", iter.Type().String())
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. internal/s3select/sql/value_test.go

    import (
    	"fmt"
    	"math"
    	"strconv"
    	"testing"
    	"time"
    )
    
    // valueBuilders contains one constructor for each value type.
    // Values should match if type is the same.
    var valueBuilders = []func() *Value{
    	FromNull,
    	func() *Value {
    		return FromBool(true)
    	},
    	func() *Value {
    		return FromBytes([]byte("byte contents"))
    	},
    	func() *Value {
    		return FromFloat(math.Pi)
    	},
    	func() *Value {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  5. internal/s3select/sql/evaluate.go

    			return nil, err
    		}
    		bs, err := elems.MarshalJSON()
    		if err != nil {
    			return nil, err
    		}
    		return FromBytes(bs), nil
    	case []Value:
    		return FromArray(rval), nil
    	case nil:
    		return FromNull(), nil
    	case Missing:
    		return FromMissing(), nil
    	}
    	return nil, fmt.Errorf("Unhandled value type: %T", result)
    }
    
    func (e *PrimaryTerm) evalNode(r Record, tableAlias string) (res *Value, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  6. internal/s3select/sql/value.go

    	return &Value{value: b}
    }
    
    // FromTimestamp creates a Value from a timestamp
    func FromTimestamp(t time.Time) *Value {
    	return &Value{value: t}
    }
    
    // FromNull creates a Value with Null value
    func FromNull() *Value {
    	return &Value{value: nil}
    }
    
    // FromMissing creates a Value with Missing value
    func FromMissing() *Value {
    	return &Value{value: Missing{}}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Feb 25 20:31:19 UTC 2022
    - 20.2K bytes
    - Viewed (0)
Back to top