Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for fromInt (0.2 sec)

  1. internal/s3select/sql/timestampfuncs.go

    	switch what {
    	case timePartYear:
    		return FromInt(int64(t.Year())), nil
    	case timePartMonth:
    		return FromInt(int64(t.Month())), nil
    	case timePartDay:
    		return FromInt(int64(t.Day())), nil
    	case timePartHour:
    		return FromInt(int64(t.Hour())), nil
    	case timePartMinute:
    		return FromInt(int64(t.Minute())), nil
    	case timePartSecond:
    		return FromInt(int64(t.Second())), nil
    	case timePartTimezoneHour:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  2. internal/s3select/simdj/record.go

    	case simdjson.TypeInt:
    		v, err := iter.Int()
    		if err != nil {
    			return nil, err
    		}
    		return sql.FromInt(v), nil
    	case simdjson.TypeUint:
    		v, err := iter.Int()
    		if err != nil {
    			// Can't fit into int, convert to float.
    			v, err := iter.Float()
    			return sql.FromFloat(v), err
    		}
    		return sql.FromInt(v), nil
    	case simdjson.TypeBool:
    		v, err := iter.Bool()
    		if err != nil {
    			return nil, err
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  3. internal/s3select/sql/aggregation.go

    	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:
    		return &aggVal{runningMax: FromInt(0)}
    	default:
    		return &aggVal{}
    	}
    }
    
    // evalAggregationNode - performs partial computation using the
    // current row and stores the result.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  4. internal/s3select/sql/value_test.go

    	FromNull,
    	func() *Value {
    		return FromBool(true)
    	},
    	func() *Value {
    		return FromBytes([]byte("byte contents"))
    	},
    	func() *Value {
    		return FromFloat(math.Pi)
    	},
    	func() *Value {
    		return FromInt(0x1337)
    	},
    	func() *Value {
    		t, err := time.Parse(time.RFC3339, "2006-01-02T15:04:05Z")
    		if err != nil {
    			panic(err)
    		}
    		return FromTimestamp(t)
    	},
    	func() *Value {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 12.5K bytes
    - Viewed (0)
  5. internal/s3select/sql/value.go

    	default:
    		return fmt.Sprintf("%v:INVALID", v.value)
    	}
    }
    
    // FromFloat creates a Value from a number
    func FromFloat(f float64) *Value {
    	return &Value{value: f}
    }
    
    // FromInt creates a Value from an int
    func FromInt(f int64) *Value {
    	return &Value{value: f}
    }
    
    // FromString creates a Value from a string
    func FromString(str string) *Value {
    	return &Value{value: str}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  6. internal/s3select/sql/evaluate.go

    	switch rval := result.(type) {
    	case string:
    		return FromString(rval), nil
    	case float64:
    		return FromFloat(rval), nil
    	case int64:
    		return FromInt(rval), nil
    	case uint64:
    		if rval <= math.MaxInt64 {
    			return FromInt(int64(rval)), nil
    		}
    		return FromFloat(float64(rval)), nil
    	case bool:
    		return FromBool(rval), nil
    	case jstream.KVS:
    		bs, err := json.Marshal(result)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 12K bytes
    - Viewed (0)
  7. internal/s3select/sql/funceval.go

    	inferTypeAsString(v)
    	s, ok := v.ToString()
    	if !ok {
    		err := fmt.Errorf("%s/%s expects a string argument", sqlFnCharLength, sqlFnCharacterLength)
    		return nil, errIncorrectSQLFunctionArgumentType(err)
    	}
    	return FromInt(int64(len([]rune(s)))), nil
    }
    
    func lowerCase(v *Value) (*Value, error) {
    	inferTypeAsString(v)
    	s, ok := v.ToString()
    	if !ok {
    		err := fmt.Errorf("%s expects a string argument", sqlFnLower)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 13.2K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/net_test.go

    					Port: intstr.FromString("foo-2-port"),
    				},
    			},
    		},
    		StartupProbe: &corev1.Probe{
    			ProbeHandler: corev1.ProbeHandler{
    				HTTPGet: &corev1.HTTPGetAction{
    					Port: intstr.FromInt(7777),
    				},
    			},
    		},
    	}
    
    	containers := []corev1.Container{app1}
    
    	var podStatus corev1.PodStatus
    	if v6IP {
    		podStatus = corev1.PodStatus{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
  9. istioctl/pkg/describe/describe_test.go

    						Selector: map[string]string{
    							"app": "productpage",
    						},
    						Ports: []corev1.ServicePort{
    							{
    								Name:       "http",
    								Port:       9080,
    								TargetPort: intstr.FromInt(9080),
    							},
    						},
    					},
    				},
    				&corev1.Service{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      "istio-ingressgateway",
    						Namespace: "default",
    					},
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Mar 28 09:54:01 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    }
    
    // performs a http request to remote endpoint to check if deployment id of remote endpoint is same as
    // local cluster deployment id. This is to prevent replication to self, especially in case of a loadbalancer
    // in front of MinIO.
    func checkRemoteEndpoint(ctx context.Context, epURL *url.URL) error {
    	reqURL := &url.URL{
    		Scheme: epURL.Scheme,
    		Host:   epURL.Host,
    		Path:   healthCheckPathPrefix + healthCheckReadinessPath,
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top