- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 37 for scrollTo (0.05 seconds)
-
src/test/java/org/codelibs/fess/query/QueryFieldConfigTest.java
String[] fields = { "scroll1", "scroll2", "scroll3" }; queryFieldConfig.setScrollResponseFields(fields); String[] result = queryFieldConfig.getScrollResponseFields(); assertSame(fields, result); } @Test public void test_setScrollResponseFields() { String[] fields = { "scroll1", "scroll2", "scroll3" };
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 33.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/util/ScrollOperationHelper.java
response = client.prepareSearchScroll(scrollId) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout()); if (!scrollId.equals(response.getScrollId())) { SuggestUtil.deleteScrollContext(client, scrollId); } scrollId = response.getScrollId(); }
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 9.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
response = client.prepareSearchScroll(scrollId) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout()); if (!scrollId.equals(response.getScrollId())) { SuggestUtil.deleteScrollContext(client, scrollId); } }
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 11.1K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
} return count; } /** * Clears a scroll context. * * @param scrollId The scroll ID to clear. */ public void clearScroll(final String scrollId) { if (scrollId != null) { prepareClearScroll().addScrollId(scrollId)Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Nov 23 02:01:26 GMT 2025 - 26.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
* @param client the OpenSearch client used to clear the scroll context * @param scrollId the ID of the scroll context to be deleted; if null, no action is taken */ public static void deleteScrollContext(final Client client, final String scrollId) { if (scrollId != null) { client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(res -> {}, e -> {})); } } /**Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Nov 23 11:21:40 GMT 2025 - 17.5K bytes - Click Count (1) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
deleteScrollContext(scrollId); } return count; } /** * Deletes a scroll context to free resources. * * @param scrollId the scroll ID to delete */ protected void deleteScrollContext(final String scrollId) { if (scrollId != null) { client.prepareClearScroll() .addScrollId(scrollId)
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 138.6K bytes - Click Count (1) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java
when(mockSearchResponse.getScrollId()).thenReturn("scroll1", "scroll1"); when(mockSearchResponse.getHits()).thenReturn(mockSearchHits); when(mockSearchHits.getHits()).thenReturn(new SearchHit[] { mockHit }, new SearchHit[0]); when(mockHit.getIndex()).thenReturn("test-index"); when(mockHit.getId()).thenReturn("doc1"); // Setup scroll response (empty on second call)
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Mon Jan 12 06:25:38 GMT 2026 - 16.9K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
} final String sid = scrollId; response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute()); if (!scrollId.equals(response.getScrollId())) { getClient().clearScroll(scrollId); } scrollId = response.getScrollId(); } } finally {Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Nov 20 08:40:57 GMT 2025 - 34.3K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
docIds.addAll(resultIds); Map<String, Object> scrollBody = new HashMap<>(); scrollBody.put("scroll", "1m"); scrollBody.put("scroll_id", scrollId); response = given().contentType("application/json").body(scrollBody).get(getEsUrl() + "/_search/scroll"); jsonPath = JsonPath.from(response.asString()); } for (String docId : docIds) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 10.6K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java
} final String sid = scrollId; response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute()); if (!scrollId.equals(response.getScrollId())) { getClient().clearScroll(scrollId); } scrollId = response.getScrollId(); } } finally {Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 11.1K bytes - Click Count (0)