Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 3,501 for s3object (0.07 sec)

  1. internal/s3select/sql/parser_test.go

    		participle.CaseInsensitive("Timeword"),
    	)
    
    	j := JSONPath{}
    	cases := []string{
    		"S3Object",
    		"S3Object.id",
    		"S3Object.book.title",
    		"S3Object.id[1]",
    		"S3Object.id['abc']",
    		"S3Object.id['ab']",
    		"S3Object.words.*.id",
    		"S3Object.words.name[*].val",
    		"S3Object.words.name[*].val[*]",
    		"S3Object.words.name[*].val.*",
    	}
    	for i, tc := range cases {
    		err := p.ParseString(tc, &j)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. internal/s3select/select_test.go

    			query: `select "na.me" from S3Object s`,
    			wantResult: `apple
    mango`,
    		},
    		{
    			name:       "Select column containing dot with table name prefix",
    			query:      `select count(S3Object."na.me") from S3Object`,
    			wantResult: `2`,
    		},
    		{
    			name:  "Select column containing dot with table alias prefix",
    			query: `select s."na.me" from S3Object as s`,
    			wantResult: `apple
    mango`,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  3. internal/s3select/sql/statement.go

    		if err = input.Replace(kvs); err != nil {
    			return nil, err
    		}
    
    		return []*Record{&input}, nil
    	case simdjson.Object:
    		txedRec, _, err := jsonpathEval(e.selectAST.From.Table.PathExpr[1:], rec)
    		if err != nil {
    			return nil, err
    		}
    
    		switch v := txedRec.(type) {
    		case simdjson.Object:
    			err := input.Replace(v)
    			if err != nil {
    				return nil, err
    			}
    
    		case []interface{}:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. internal/s3select/select_benchmark_test.go

    				b.Fatal(err)
    			}
    
    			s3Select.Evaluate(&nullResponseWriter{})
    			s3Select.Close()
    		}
    	})
    }
    
    func benchmarkSelectAll(b *testing.B, count int) {
    	benchmarkSelect(b, count, "select * from S3Object")
    }
    
    // BenchmarkSelectAll_100K - benchmark * function with 100k records.
    func BenchmarkSelectAll_100K(b *testing.B) {
    	benchmarkSelectAll(b, 100*humanize.KiByte)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  5. docs/select/README.md

    Please replace ``endpoint_url``,``aws_access_key_id``, ``aws_secret_access_key``, ``Bucket`` and ``Key`` with your local setup in this ``select.py`` file.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 6.5K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    		// do an additional verification whether object exists when object is deletemarker and request
    		// is from replication
    		if opts.CheckDMReplicationReady {
    			topts := opts
    			topts.VersionID = ""
    			goi, gerr := getObjectInfo(ctx, bucket, object, topts)
    			if gerr == nil || goi.VersionID != "" { // object layer returned more info because object is deleted
    				w.Header().Set(xhttp.MinIOTargetReplicationReady, "true")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    			online++
    		}
    	}
    	return online
    }
    
    // CopyObject - copy object source object to destination object.
    // if source object and destination object are same we only
    // update metadata.
    func (er erasureObjects) CopyObject(ctx context.Context, srcBucket, srcObject, dstBucket, dstObject string, srcInfo ObjectInfo, srcOpts, dstOpts ObjectOptions) (oi ObjectInfo, err error) {
    	if !dstOpts.NoAuditLog {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  8. cmd/object-multipart-handlers.go

    		}
    	}
    
    	srcInfo.PutObjReader = pReader
    	copyObjectPart := objectAPI.CopyObjectPart
    
    	// Copy source object to destination, if source and destination
    	// object is same then only metadata is updated.
    	partInfo, err := copyObjectPart(ctx, srcBucket, srcObject, dstBucket, dstObject, uploadID, partID,
    		startOffset, length, srcInfo, srcOpts, dstOpts)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  9. cmd/object-api-interface.go

    	Limit        int                      // maximum number of items, 0 means no limit
    }
    
    // ExpirationOptions represents object options for object expiration at objectLayer.
    type ExpirationOptions struct {
    	Expire bool
    }
    
    // TransitionOptions represents object options for transition ObjectLayer operation
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  10. cmd/object-handlers_test.go

    				// Read last byte of object
    				fmt.Sprintf("bytes=-%d", 1),
    				// Read all but first byte of object
    				"bytes=1-",
    				// Read first half of object
    				fmt.Sprintf("bytes=%d-%d", 0, objLen/2),
    				// Read last half of object
    				fmt.Sprintf("bytes=-%d", objLen/2),
    				// Read middle half of object
    				fmt.Sprintf("bytes=%d-%d", objLen/4, objLen*3/4),
    				// Read 100MiB of the object from the beginning
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
Back to top