- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for prepareSearch (0.2 sec)
-
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java
urlQueueService.insert(urlQueue); assertTrue(fesenClient.prepareSearch("fess_crawler.queue").setQuery(QueryBuilders.termQuery("sessionId", "sessionId")).setSize(0) .execute().actionGet().getHits().getTotalHits().value > 0); urlQueueService.delete("sessionId"); assertFalse(fesenClient.prepareSearch("fess_crawler.queue").setQuery(QueryBuilders.termQuery("sessionId", "sessionId")).setSize(0)
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 5.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java
public List<OpenSearchAccessResult> getAccessResultList(final Consumer<SearchRequestBuilder> callback) { final SearchResponse response = getClient().get(c -> { final SearchRequestBuilder builder = c.prepareSearch(index); callback.accept(builder); builder.setFetchSource(new String[] { "parentUrl", "method", "mimeType", "sessionId", "url", "executionTime", "createTime",
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 8.5K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
} } public int getCount(final Consumer<SearchRequestBuilder> callback) { final TotalHits totalHits = getClient().get(c -> { final SearchRequestBuilder builder = c.prepareSearch(index).setSize(0).setTrackTotalHits(true); callback.accept(builder); return builder.execute(); }).getHits().getTotalHits(); return totalHits != null ? (int) totalHits.value : 0;
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
client.search(request, listener); } @Override public SearchRequestBuilder prepareSearch(final String... indices) { final SearchRequestBuilder builder = client.prepareSearch(indices); if (searchPreference != null) { builder.setPreference(searchPreference); } return builder; } @Override
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 19.9K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
sessionCache.clear(); } @Override public void updateSessionId(final String oldSessionId, final String newSessionId) { SearchResponse response = getClient().get(c -> c.prepareSearch(index).setScroll(new TimeValue(scrollTimeout)) .setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, oldSessionId))).setSize(scrollSize) .execute());
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0)