- Sort Score
- Result 10 results
- Languages All
Results 51 - 58 of 58 for Account (0.15 sec)
-
docs/bigdata/README.md
scala> counts.saveAsTextFile("s3a://testbucket/wordcount") ``` Use one of the following approaches to view job output: View output in the Scala shell: ``` scala> counts.count() 364 ``` To view the output from MinIO exit the Scala shell. View WordCount job status: ``` hadoop fs -ls s3a://testbucket/wordcount ``` The output should be similar to the following:
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
var complete = (upstream == null) /** The most recently read bytes from [upstream]. This is a suffix of [file]. Guarded by this. */ val buffer = Buffer() /** * Reference count of the number of active sources reading this stream. When decremented to 0 * resources are released and all following calls to [.newSource] return null. Guarded by this. */ var sourceCount = 0 val isClosed: Boolean
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_cluster_health_drives_offline_count` | `gauge` | Count of offline drives in the cluster | | | `minio_cluster_health_drives_online_count` | `gauge` | Count of online drives in the cluster | | | `minio_cluster_health_drives_count` | `gauge` | Count of all drives in the cluster | |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 28.5K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt
val bytes = "060229ffffff7f".decodeHex() assertFailsWith<ProtocolException> { Adapters.OBJECT_IDENTIFIER.fromDer(bytes) }.also { expected -> assertThat(expected.message).isEqualTo("unexpected byte count at OBJECT IDENTIFIER") } } /** * ``` * Point ::= SEQUENCE { * x [0] INTEGER OPTIONAL, * y [1] INTEGER OPTIONAL * } * ``` */ data class Point(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 31.7K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_node_ilm_action_count_delete_action` | Total action outcome of lifecycle checks since server start for deleting object | | `minio_node_ilm_action_count_delete_version_action` | Total action outcome of lifecycle checks since server start for deleting a version |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Hpack.kt
private fun clearDynamicTable() { dynamicTable.fill(null) nextHeaderIndex = dynamicTable.size - 1 headerCount = 0 dynamicTableByteCount = 0 } /** Returns the count of entries evicted. */ private fun evictToRecoverBytes(bytesToRecover: Int): Int { var bytesToRecover = bytesToRecover var entriesToEvict = 0 if (bytesToRecover > 0) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 22.5K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
redQueue.execute("task") { log += "run@${taskFaker.nanoTime}" } val idleLatch = redQueue.idleLatch() assertThat(idleLatch.count).isEqualTo(1) taskFaker.advanceUntil(0.µs) assertThat(log).containsExactly("run@0") assertThat(idleLatch.count).isEqualTo(0) } @Test fun multipleCallsToIdleLatchReturnSameInstance() { redQueue.execute("task") {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0) -
docs/recipes.md
} ``` This above code relies on this `responseCount` extension val: ```kotlin val Response.responseCount: Int get() = generateSequence(this) { it.priorResponse }.count() ``` === ":material-language-java: Java" ```java private final OkHttpClient client; public Authenticate() { client = new OkHttpClient.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Feb 18 08:52:22 GMT 2022 - 40.2K bytes - Viewed (1)