- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 132 for client (0.44 sec)
-
src/main/java/org/codelibs/fess/suggest/index/writer/SuggestBulkFileWriter.java
import org.codelibs.fess.suggest.entity.SuggestItem; import org.codelibs.fess.suggest.settings.SuggestSettings; import org.opensearch.client.Client; import org.opensearch.index.query.QueryBuilder; public class SuggestBulkFileWriter implements SuggestWriter { @Override public SuggestWriterResult write(final Client client, final SuggestSettings settings, final String index, final SuggestItem[] items, final boolean update) {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 1.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/request/RequestBuilder.java
import org.codelibs.fess.suggest.concurrent.Deferred; import org.opensearch.client.Client; public abstract class RequestBuilder<Req extends Request<Res>, Res extends Response> { protected Client client; protected Req request; public RequestBuilder(final Client client, final Req request) { this.client = client; this.request = request; } public Deferred<Res>.Promise execute() {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 1.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
protected String scrollId = null; protected final AtomicLong docCount = new AtomicLong(0); protected final long totalDocNum; public ESSourceReader(final Client client, final SuggestSettings settings, final String indexName) { this.client = client; this.settings = settings; this.indexName = indexName; this.supportedFields = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS);
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 7.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/writer/SuggestIndexWriter.java
import org.opensearch.action.index.IndexRequestBuilder; import org.opensearch.client.Client; import org.opensearch.common.unit.TimeValue; import org.opensearch.index.query.QueryBuilder; public class SuggestIndexWriter implements SuggestWriter { @Override public SuggestWriterResult write(final Client client, final SuggestSettings settings, final String index, final SuggestItem[] items,
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 4.2K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/CrawlerClientFactoryTest.java
url = "smb1:/home/hoge"; client = clientFactory.getClient(url); assertNotNull(client); assertTrue(client instanceof org.codelibs.fess.crawler.client.smb1.SmbClient); url = "ftp:/home/hoge"; client = clientFactory.getClient(url); assertNotNull(client); assertTrue(client instanceof FtpClient); url = "storage:/home/hoge"; client = clientFactory.getClient(url);
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 5.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/AbstractCrawlerClientTest.java
}; ResponseData responseData = new ResponseData(); responseData.setUrl("http://test.com/"); client.setMaxContentLength(1000000L); client.checkMaxContentLength(responseData); responseData.setContentLength(-1); client.checkMaxContentLength(responseData); responseData.setContentLength(1000L); client.checkMaxContentLength(responseData);
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonFactory.java
WorkerDaemonClient client = clientsManager.reserveIdleClient(forkOptions); if (client == null) { client = clientsManager.reserveNewClient(forkOptions); } return client; } }; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 13:20:59 UTC 2024 - 3.4K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
} }; client.setAccessTimeout(1); try { client.doGet("http://localhost/"); fail(); } catch (CrawlingAccessException e) { assertTrue(e.getCause() instanceof InterruptedException); } } public void test_doHead_accessTimeoutTarget() { HcHttpClient client = new HcHttpClient() { @Override
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu May 09 09:28:25 UTC 2024 - 8.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java
suggester = Suggester.builder().build(runner.client(), "SuggesterTest"); suggester.createIndexIfNothing(); } @Test public void test_Read() throws Exception { String indexName = "test-index"; Client client = runner.client(); SuggestSettings settings = suggester.settings(); int num = 10000; addDocument(indexName, client, num);
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 8.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/request/Request.java
import org.codelibs.fess.suggest.concurrent.Deferred; import org.codelibs.fess.suggest.exception.SuggesterException; import org.opensearch.client.Client; import org.opensearch.core.common.Strings; public abstract class Request<T extends Response> { public Deferred<T>.Promise execute(final Client client) { final String error = getValidationError(); if (!Strings.isNullOrEmpty(error)) {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 1.5K bytes - Viewed (0)