- Sort Score
- Result 10 results
- Languages All
Results 11 - 14 of 14 for getScrollId (0.42 sec)
-
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java
when(mockSearchBuilder.execute()).thenReturn(mockSearchFuture); when(mockSearchFuture.actionGet(anyLong(), any(TimeUnit.class))).thenReturn(mockSearchResponse); when(mockSearchResponse.getScrollId()).thenReturn("scroll1", "scroll1"); when(mockSearchResponse.getHits()).thenReturn(mockSearchHits); when(mockSearchHits.getHits()).thenReturn(new SearchHit[] { mockHit }, new SearchHit[0]);
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:44:44 UTC 2025 - 17K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
.execute() .actionGet(fessConfig.getIndexBulkTimeout()); if (!scrollId.equals(response.getScrollId())) { deleteScrollContext(scrollId); } scrollId = response.getScrollId(); } } finally { deleteScrollContext(scrollId); } return count; }
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 122.4K bytes - Viewed (1) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
if (!scrollId.equals(response.getScrollId())) { getClient().clearScroll(scrollId); } scrollId = response.getScrollId(); } } finally { getClient().clearScroll(scrollId); } refresh(); }
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 34.3K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
SearchResponse response = get(c -> c.prepareSearch(index).setScroll(scrollForDelete).setSize(sizeForDelete).setQuery(queryBuilder).execute()); String scrollId = response.getScrollId(); int count = 0; try { while (scrollId != null) { final SearchHit[] hits = response.getHits().getHits(); if (hits.length == 0) {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 02:01:26 UTC 2025 - 26.2K bytes - Viewed (0)