- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for Execute (0.02 sec)
-
README.md
Crawler crawler2 = container.getComponent("crawler"); crawler2.setSessionId("session2"); crawler2.addUrl("https://site2.com"); // Execute concurrently crawler1.setBackground(true); crawler2.setBackground(true); String sessionId1 = crawler1.execute(); String sessionId2 = crawler2.execute(); crawler1.awaitTermination(); crawler2.awaitTermination(); ``` ### Custom Interval Control ```java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 15.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
crawler2.getCrawlerContext().setMaxAccessCount(maxCount); crawler2.getCrawlerContext().setNumOfThread(numOfThread); final String sessionId1 = crawler1.execute(); final String sessionId2 = crawler2.execute(); assertNotSame(sessionId1, sessionId2); assertNotSame(crawler1.crawlerContext, crawler2.crawlerContext);
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 19.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
} response = builder.execute().actionGet(settings.getSearchTimeout()); } else { response = client.prepareSearchScroll(scrollId) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout());Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 11K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/SuggesterTest.java
assertEquals(1, response.getNum()); assertEquals("全文 検索", response.getWords().get(0)); response = suggester.suggest().addKind("query").execute().getResponse(); assertEquals(1, response.getNum()); SuggestResponse response2 = suggester.suggest().setSuggestDetail(true).execute().getResponse();
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 37.2K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
return bulkBuilder.execute(); }); if (bulkResponse.hasFailures()) { throw new OpenSearchAccessException(bulkResponse.buildFailureMessage()); } final String sid = scrollId; response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 34.2K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java
.execute() .actionGet() .getHits() .getTotalHits() .value() > 0); assertTrue(fesenClient.prepareSearch("fess_crawler.queue") .setQuery(QueryBuilders.termQuery("sessionId", "id2")) .execute() .actionGet() .getHits()Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 5.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/Suggester.java
.addAlias(new Alias(getUpdateAlias(index))) .execute() .actionGet(suggestSettings.getIndicesTimeout()); client.admin().cluster().prepareHealth().setWaitForYellowStatus().execute().actionGet(suggestSettings.getClusterTimeout()); created = true; } return created;
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 20.7K bytes - Viewed (3) -
src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java
.setSettings(settings) .execute() .actionGet(this.settings.getIndicesTimeout()); } /** * Deletes the analyzer settings. */ protected void deleteAnalyzerSettings() { client.admin().indices().prepareDelete(analyzerSettingsIndexName).execute().actionGet(settings.getIndicesTimeout()); } /**
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 26.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/request/RequestBuilder.java
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 1.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
SearchResponse response = client.prepareSearch(index) .setQuery(queryBuilder) .setSize(500) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout()); String scrollId = response.getScrollId(); try { while (scrollId != null) {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Mon Sep 01 13:33:03 UTC 2025 - 17.4K bytes - Viewed (1)