- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 78 for shard (0.02 sec)
-
src/main/java/org/codelibs/fess/crawler/util/FessCrawlerConfig.java
/** * Gets the number of shards for the queue index. * * @return the number of queue shards */ @Override public int getQueueShards() { return ComponentUtil.getFessConfig().getIndexDocumentCrawlerQueueNumberOfShardsAsInteger(); } /** * Gets the number of shards for the data index. * * @return the number of data shards */ @Override
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 3.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/DefaultQueryBuilder.java
public String getWriteableName() { return queryBuilder.getWriteableName(); } /** * Creates a Lucene Query from this query builder. * * @param context the query shard context * @return the Lucene Query * @throws IOException if an I/O error occurs */ @Override public Query toQuery(final QueryShardContext context) throws IOException {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.6K bytes - Viewed (0) -
src/main/resources/fess_label_it.properties
labels.searchlog_usersessionid=ID utente labels.searchlog_requestedtime=Ora labels.searchlog_accesstype=Tipo di accesso labels.maintenance_title_configuration=Manutenzione labels.number_of_shards_for_doc=Numero di shard labels.auto_expand_replicas_for_doc=Numero massimo di repliche labels.clear_crawler_index=Indice crawler labels.clear_crawler_index_button=Elimina indice crawler labels.diagnostic_logs=Diagnostica
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 10 04:56:21 UTC 2025 - 43.4K bytes - Viewed (0) -
src/main/resources/fess_config.properties
index.document.suggest.index=fess # Index name for crawler documents. index.document.crawler.index=fess_crawler # Number of primary shards for crawler queue index. index.document.crawler.queue.number_of_shards=10 # Number of primary shards for crawler data index. index.document.crawler.data.number_of_shards=10 # Number of primary shards for crawler filter index. index.document.crawler.filter.number_of_shards=10 # Number of replicas for crawler queue index.
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 05 14:45:37 UTC 2025 - 54.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
/** * Get the value for the key 'searchlog.agg.shard.size'. <br> * The value is, e.g. -1 <br> * comment: searchlog * @return The value of found property. (NotNull: if not found, exception but basically no way) */ String getSearchlogAggShardSize(); /** * Get the value for the key 'searchlog.agg.shard.size' as {@link Integer}. <br> * The value is, e.g. -1 <br>
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 525.6K bytes - Viewed (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
import okhttp3.internal.okHttpName import okhttp3.internal.threadFactory /** * A set of worker threads that are shared among a set of task queues. * * Use [INSTANCE] for a task runner that uses daemon threads. There is not currently a shared * instance for non-daemon threads. * * The task runner is also responsible for releasing held threads when the library is unloaded.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 10.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt
assertThat(original.interceptors.size).isEqualTo(0) assertThat(original.networkInterceptors.size).isEqualTo(0) } /** * When copying the client, stateful things like the connection pool are shared across all * clients. */ @Test fun cloneSharesStatefulInstances() { val client = clientTestRule.newClient() // Values should be non-null. val a = client.newBuilder().build()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 13.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
/** An HTTP request that came into the mock web server. */ public class RecordedRequest( /** * The index of the socket connection that carried this request. If two recorded requests share a * connection index, they also shared a socket connection. */ public val connectionIndex: Int, /** * The index of this exchange on its HTTP connection. A request is uniquely identified by the
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 3.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
import okhttp3.internal.isHealthy import okhttp3.internal.tls.OkHostnameVerifier import okio.Buffer /** * A connection to a remote web server capable of carrying 1 or more concurrent streams. * * Connections are shared in a connection pool. Accesses to the connection's state must be guarded * by holding a lock on the connection. */ class RealConnection internal constructor( val taskRunner: TaskRunner,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 14.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
/** Number of delayed unassigned shards */ public int delayedUnassignedShards; /** Number of unassigned shards */ public int unassignedShards; /** Number of initializing shards */ public int initializingShards; /** Number of relocating shards */ public int relocatingShards; /** Percentage of active shards */ public double activeShardsPercent;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.7K bytes - Viewed (0)