- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for scrollId (0.06 sec)
-
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); } }
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 11.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java
response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout); if (!scrollId.equals(response.getScrollId())) { deleteScrollContext(scrollId); } scrollId = response.getScrollId(); } } finally { deleteScrollContext(scrollId); } }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 27 07:01:25 UTC 2025 - 26.4K bytes - Viewed (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)Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 02:01:26 UTC 2025 - 26.2K bytes - Viewed (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 {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 11.1K bytes - Viewed (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 -> {})); } } /**Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Sun Nov 23 11:21:40 UTC 2025 - 17.5K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java
response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout); if (!scrollId.equals(response.getScrollId())) { deleteScrollContext(scrollId); } scrollId = response.getScrollId(); } } finally { deleteScrollContext(scrollId); } }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 27 07:01:25 UTC 2025 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java
response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout); if (!scrollId.equals(response.getScrollId())) { deleteScrollContext(scrollId); } scrollId = response.getScrollId(); } } finally { deleteScrollContext(scrollId); } }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 27 07:01:25 UTC 2025 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
if (!scrollId.equals(response.getScrollId())) { SuggestUtil.deleteScrollContext(client, scrollId); } scrollId = response.getScrollId(); } } finally { SuggestUtil.deleteScrollContext(client, scrollId); }
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 34.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java
response = client.prepareSearchScroll(scrollId) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout()); if (!scrollId.equals(response.getScrollId())) { SuggestUtil.deleteScrollContext(client, scrollId); }
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 15.8K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.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 {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 16.9K bytes - Viewed (1)