- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for _shards (0.43 sec)
-
src/main/resources/fess_config.properties
index.document.update.index=fess.update index.document.suggest.index=fess index.document.crawler.index=fess_crawler index.document.crawler.queue.number_of_shards=10 index.document.crawler.data.number_of_shards=10 index.document.crawler.filter.number_of_shards=10 index.document.crawler.queue.number_of_replicas=1 index.document.crawler.data.number_of_replicas=1 index.document.crawler.filter.number_of_replicas=1
Properties - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Apr 11 02:34:53 GMT 2024 - 30.6K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
String INDEX_DOCUMENT_CRAWLER_QUEUE_number_of_shards = "index.document.crawler.queue.number_of_shards"; /** The key of the configuration. e.g. 10 */ String INDEX_DOCUMENT_CRAWLER_DATA_number_of_shards = "index.document.crawler.data.number_of_shards"; /** The key of the configuration. e.g. 10 */ String INDEX_DOCUMENT_CRAWLER_FILTER_number_of_shards = "index.document.crawler.filter.number_of_shards";
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Apr 11 02:34:53 GMT 2024 - 459.2K bytes - Viewed (4) -
docs/debugging/xl-meta/main.go
mapped = make([]byte, size) filled = make([]byte, size) } data = ei.V2Obj.EcM parity = ei.V2Obj.EcN if shards == 0 { shards = data + parity } idx = ei.V2Obj.EcIndex - 1 fmt.Println("Read shard", ei.V2Obj.EcIndex, "Data shards", data, "Parity", parity, fmt.Sprintf("(%s)", file)) if ei.V2Obj.Size != size { return fmt.Errorf("size mismatch. Meta size: %d", ei.V2Obj.Size) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/erasure-decode.go
// Reading first time on this disk, hence the buffer needs to be allocated. // Subsequent reads will reuse this buffer. p.buf[bufIdx] = make([]byte, p.shardSize) } // For the last shard, the shardsize might be less than previous shard sizes. // Hence the following statement ensures that the buffer size is reset to the right size. p.buf[bufIdx] = p.buf[bufIdx][:p.shardSize] n, err := rr.ReadAt(p.buf[bufIdx], p.offset)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/notification.go
// To avoid these problems we must split the work at scale. With 1000 node // setup becoming a reality we must try to shard the work properly such as // pick 10 nodes that precisely can send those 100 requests the first node // in the 10 node shard would coordinate between other 9 shards to get the // rest of the `99*9` requests. // // This essentially splits the workload properly and also allows for network
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
this.executorServiceOrNull = executorService } internal fun enqueue(call: AsyncCall) { this.withLock { readyAsyncCalls.add(call) // Mutate the AsyncCall so that it shares the AtomicInteger of an existing running call to // the same host. if (!call.call.forWebSocket) { val existingCall = findExistingCallWithHost(call.host)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
cmd/erasure-metadata.go
// In this case, parity == 0 implies that this object version is a // delete marker readQuorum = N/2 + 1 } if occ < readQuorum { // Ignore this parity since we don't have enough shards for read quorum continue } if occ > maxOcc { maxOcc = occ cparity = parity } } if maxOcc == 0 { // Did not found anything useful return -1 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
CREDITS
"control" means (i) the power, direct or indirect, to cause the direction or management of such entity, whether by contract or otherwise, or (ii) ownership of fifty percent (50%) or more of the outstanding shares, or (iii) beneficial ownership of such entity. "You" (or "Your") shall mean an individual or Legal Entity exercising permissions granted by this License.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:31:35 GMT 2024 - 1.6M bytes - Viewed (0) -
licenses/cloud.google.com/go/auth/oauth2adapt/LICENSE
"control" means (i) the power, direct or indirect, to cause the direction or management of such entity, whether by contract or otherwise, or (ii) ownership of fifty percent (50%) or more of the outstanding shares, or (iii) beneficial ownership of such entity. "You" (or "Your") shall mean an individual or Legal Entity exercising permissions granted by this License.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 13:56:46 GMT 2024 - 11.1K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
_2020-03-08_ * Fix: Don't reuse a connection on redirect if certs match but DNS does not. For better locality and performance OkHttp attempts to use the same pooled connection across redirects and follow-ups. It independently shares connections when the IP addresses and certificates match, even if the host names do not. In 4.4.0 we introduced a regression where we shared a connection
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0)