- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for prepareSearchScroll (0.09 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
client.searchScroll(request, listener); } @Override public SearchScrollRequestBuilder prepareSearchScroll(final String scrollId) { return client.prepareSearchScroll(scrollId); } @Override public ActionFuture<MultiSearchResponse> multiSearch(final MultiSearchRequest request) { return client.multiSearch(request);
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/OpenSearchDataService.java
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/OpenSearchUrlQueueService.java
throw new OpenSearchAccessException(bulkResponse.buildFailureMessage()); } final String sid = scrollId; response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute()); if (!scrollId.equals(response.getScrollId())) { getClient().clearScroll(scrollId); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
throw new OpenSearchAccessException(bulkResponse.buildFailureMessage()); } final String sid = scrollId; response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute()); if (!scrollId.equals(response.getScrollId())) { getClient().clearScroll(scrollId); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K bytes - Viewed (0)