- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for prepareSearchScroll (0.1 sec)
-
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
if (result.hasFailure()) { throw new SuggestIndexException(result.getFailures().get(0)); } response = client.prepareSearchScroll(scrollId).execute().actionGet(settings.getSearchTimeout()); if (!scrollId.equals(response.getScrollId())) { SuggestUtil.deleteScrollContext(client, scrollId); }
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 34.8K bytes - Viewed (0) -
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 Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 25.3K 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) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 10.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java
for (final SearchHit hit : hits) { array[count] = hit.getSourceAsMap(); count++; } 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 - 15.6K 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 Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java
fieldContentsAnalyzer, fieldContentsReadingAnalyzer)); } 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 - 26.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
* * @param scrollId the scroll ID * @return the search scroll request builder */ @Override public SearchScrollRequestBuilder prepareSearchScroll(final String scrollId) { return client.prepareSearchScroll(scrollId); } /** * Executes a multi-search request asynchronously. * * @param request the multi-search request
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
if (bulkResponse.hasFailures()) { throw new SuggesterException(bulkResponse.buildFailureMessage()); } response = client.prepareSearchScroll(scrollId) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout());
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Mon Sep 01 13:33:03 UTC 2025 - 17.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 Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 34.2K bytes - Viewed (0)