- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for cdef (0.17 sec)
-
cmd/erasure-server-pool.go
// // import org.apache.spark.sql.SparkSession // import org.apache.spark.sql.types.{IntegerType, StringType, StructField, StructType} // object SparkJSONRead { // def main(args: Array[String]): Unit = { // val spark:SparkSession = SparkSession.builder() // .appName("SparkByExample") // .master("local[1]").getOrCreate() //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
// Valid object and bucket names but non-existent bucket. {bucketName: "abc", objName: "def", uploadID: resN.UploadID, PartID: 1, expectedError: fmt.Errorf("%s", "Bucket not found: abc")}, // Test Case - 7. // Existing bucket, but using a bucket on which NewMultipartUpload is not Initiated. {bucketName: "unused-bucket", objName: "def", uploadID: "xyz", PartID: 1, expectedError: fmt.Errorf("%s", "Invalid upload id xyz")}, // Test Case - 8.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
cmd/object-api-utils_test.go
// Remove doubled slash {"abc//def//ghi", "abc/def/ghi"}, {"//abc", "/abc"}, {"///abc", "/abc"}, {"//abc//", "/abc"}, {"abc//", "abc"}, // Remove . elements {"abc/./def", "abc/def"}, {"/./abc/def", "/abc/def"}, {"abc/.", "abc"}, // Remove .. elements {"abc/def/ghi/../jkl", "abc/def/jkl"}, {"abc/def/../ghi/../jkl", "abc/jkl"}, {"abc/def/..", "abc"}, {"abc/def/../..", "."},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 23.4K bytes - Viewed (0) -
internal/grid/types_test.go
t.Errorf("MSS: %v != %v", v, v2) } } func BenchmarkMarshalMsgMSS(b *testing.B) { v := MSS{"abc": "def", "ghi": "jkl"} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgMSS(b *testing.B) { v := MSS{"abc": "def", "ghi": "jkl"} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts)))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/xl-storage_test.go
{ srcVol: "success-vol", srcPath: "abc", expectedListDir: []string{"def/", "xyz/"}, expectedErr: nil, }, // TestXLStorage case - 1. // valid case with existing volume and file to delete. { srcVol: "success-vol", srcPath: "abc/def", expectedListDir: []string{"ghi/"}, expectedErr: nil, }, // TestXLStorage case - 1.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 66.7K bytes - Viewed (0) -
cmd/object-api-putobject_test.go
4: {bucketName: bucket, inputData: []byte(""), expectedError: ObjectNameInvalid{Bucket: bucket, Object: ""}}, // Valid object and bucket names but non-existent bucket. 5: {bucketName: "abc", objName: "def", inputData: []byte(""), expectedError: BucketNotFound{Bucket: "abc"}}, // Input to replicate Md5 mismatch. 6: { bucketName: bucket, objName: object, inputData: []byte(""),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 25.8K bytes - Viewed (0) -
docs/bucket/notifications/README.md
```py #!/usr/bin/env python3 from __future__ import print_function import paho.mqtt.client as mqtt # This is the Subscriber def on_connect(client, userdata, flags, rc): print("Connected with result code "+str(rc)) # qos level is set to 1 client.subscribe("minio", 1) def on_message(client, userdata, msg): print(msg.payload)
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2)