Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 69 for plit (0.17 sec)

  1. internal/s3select/sql/parser.go

    	// Remove enclosing parenthesis.
    	n := len(values[0])
    	r := values[0][1 : n-1]
    	// Translate doubled quotes
    	*ls = LiteralList(strings.Split(r, ","))
    	return nil
    }
    
    // ObjectKey is a type for parsed strings occurring in key paths
    type ObjectKey struct {
    	Lit *LiteralString `parser:" \"[\" @LitString \"]\""`
    	ID  *Identifier    `parser:"| \".\" @@"`
    }
    
    // QuotedIdentifier is a type for parsed strings that are double
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  2. internal/config/lambda/event/arn.go

    	// ARN must be in the format of arn:minio:s3-object-lambda:<REGION>:<ID>:<TYPE>
    	if !strings.HasPrefix(s, "arn:minio:s3-object-lambda:") {
    		return nil, &ErrInvalidARN{s}
    	}
    
    	tokens := strings.Split(s, ":")
    	if len(tokens) != 6 {
    		return nil, &ErrInvalidARN{s}
    	}
    
    	if tokens[4] == "" || tokens[5] == "" {
    		return nil, &ErrInvalidARN{s}
    	}
    
    	return &ARN{
    		region: tokens[3],
    		TargetID: TargetID{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 1.6K bytes
    - Viewed (0)
  3. internal/event/targetid.go

    	if err != nil {
    		return err
    	}
    
    	*tid = *targetID
    	return nil
    }
    
    // parseTargetID - parses string to TargetID.
    func parseTargetID(s string) (*TargetID, error) {
    	tokens := strings.Split(s, ":")
    	if len(tokens) != 2 {
    		return nil, fmt.Errorf("invalid TargetID format '%v'", s)
    	}
    
    	return &TargetID{
    		ID:   tokens[0],
    		Name: tokens[1],
    	}, nil
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 1.8K bytes
    - Viewed (0)
  4. internal/arn/arn.go

    			arn.ResourceType + "/" + arn.ResourceID,
    		},
    		":",
    	)
    }
    
    // Parse - parses an ARN string into a type.
    func Parse(arnStr string) (arn ARN, err error) {
    	ps := strings.Split(arnStr, ":")
    	if len(ps) != 6 || ps[0] != string(arnPrefixArn) {
    		err = errors.New("invalid ARN string format")
    		return
    	}
    
    	if ps[1] != string(arnPartitionMinio) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 08:31:34 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    	for _, uploadID := range uploadIDs {
    		if populatedUploadIDs.Contains(uploadID) {
    			continue
    		}
    		// If present, use time stored in ID.
    		startTime := time.Now()
    		if split := strings.Split(uploadID, "x"); len(split) == 2 {
    			t, err := strconv.ParseInt(split[1], 10, 64)
    			if err == nil {
    				startTime = time.Unix(0, t)
    			}
    		}
    		uploads = append(uploads, MultipartInfo{
    			Bucket:    bucket,
    			Object:    object,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex.go

    	// Quorum is effectively = total clients subtracted with tolerance limit
    	quorum := len(restClnts) - tolerance
    	if !isReadLock {
    		// In situations for write locks, as a special case
    		// to avoid split brains we make sure to acquire
    		// quorum + 1 when tolerance is exactly half of the
    		// total locker clients.
    		if quorum == tolerance {
    			quorum++
    		}
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  7. cmd/object-api-options.go

    			valid = false
    			return
    		}
    	}
    
    	return
    }
    
    func parseObjectAttributes(h http.Header) (attributes map[string]struct{}) {
    	attributes = make(map[string]struct{})
    	for _, v := range strings.Split(strings.TrimSpace(h.Get(xhttp.AmzObjectAttributes)), ",") {
    		if v != "" {
    			attributes[v] = struct{}{}
    		}
    	}
    
    	return
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    	}
    
    	var types madmin.MetricType
    	if t, _ := strconv.ParseUint(r.Form.Get("types"), 10, 64); t != 0 {
    		types = madmin.MetricType(t)
    	} else {
    		types = madmin.MetricsAll
    	}
    
    	disks := strings.Split(r.Form.Get("disks"), ",")
    	byDisk := strings.EqualFold(r.Form.Get("by-disk"), "true")
    	var diskMap map[string]struct{}
    	if len(disks) > 0 && disks[0] != "" {
    		diskMap = make(map[string]struct{}, len(disks))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  9. docs/bigdata/README.md

    ```
    scala> val file = sc.textFile("s3a://testbucket/testdata")
    file: org.apache.spark.rdd.RDD[String] = s3a://testbucket/testdata MapPartitionsRDD[1] at textFile at <console>:24
    
    scala> val counts = file.flatMap(line => line.split(" ")).map(word => (word, 1)).reduceByKey(_ + _)
    counts: org.apache.spark.rdd.RDD[(String, Int)] = ShuffledRDD[4] at reduceByKey at <console>:25
    
    scala> counts.saveAsTextFile("s3a://testbucket/wordcount")
    ```
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 14.7K bytes
    - Viewed (0)
  10. cmd/generic-handlers.go

    		// if the caller sends path of following style
    		// a/a/a/a/a/a/a/a...
    		return true
    	}
    	path = filepath.ToSlash(strings.TrimSpace(path)) // For windows '\' must be converted to '/'
    	for _, p := range strings.Split(path, SlashSeparator) {
    		switch strings.TrimSpace(p) {
    		case dotdotComponent:
    			return true
    		case dotComponent:
    			return true
    		}
    	}
    	return false
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 01:08:52 GMT 2024
    - 20.7K bytes
    - Viewed (0)
Back to top