- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for prepareClearScroll (0.05 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
client.explain(request, listener); } @Override public ClearScrollRequestBuilder prepareClearScroll() { return client.prepareClearScroll(); } @Override public ActionFuture<ClearScrollResponse> clearScroll(final ClearScrollRequest request) { return client.clearScroll(request); }
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/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java
when(mockBulkFuture.actionGet(anyLong(), any(TimeUnit.class))).thenReturn(mockBulkResponse); when(mockBulkResponse.hasFailures()).thenReturn(false); // Setup clear scroll when(mockClient.prepareClearScroll()).thenReturn(mockClearScrollBuilder); when(mockClearScrollBuilder.addScrollId(any(String.class))).thenReturn(mockClearScrollBuilder); doAnswer(invocation -> {
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/config/allcommon/EsAbstractBehavior.java
} finally { deleteScrollContext(scrollId); } } protected void deleteScrollContext(final String scrollId) { if (scrollId != null) { client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {})); } } @Override protected Number doReadNextVal() {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
} finally { deleteScrollContext(scrollId); } } protected void deleteScrollContext(final String scrollId) { if (scrollId != null) { client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {})); } } @Override protected Number doReadNextVal() {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/util/SuggestUtil.java
*/ public static void deleteScrollContext(final Client client, final String scrollId) { if (scrollId != null) { client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(res -> {}, e -> {})); } } /** * Escapes wildcard characters in the given query string. *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
} finally { deleteScrollContext(scrollId); } } protected void deleteScrollContext(final String scrollId) { if (scrollId != null) { client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {})); } } @Override protected Number doReadNextVal() {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/client/SearchEngineClient.java
/** * Prepares a clear scroll request builder. * * @return the clear scroll request builder */ @Override public ClearScrollRequestBuilder prepareClearScroll() { return client.prepareClearScroll(); } /** * Clears scroll contexts asynchronously. * * @param request the clear scroll request * @return a future for the clear scroll responseRegistered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 122.4K bytes - Viewed (1)