- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for scrolled (0.21 sec)
-
src/main/java/org/codelibs/fess/es/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); } }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 26.4K bytes - Viewed (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) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/BaseApiManager.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 4.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/SearchEngineUtil.java
return getXContentBuilderOutputStream((builder, params) -> xContent.toXContent(builder, params), mediaType); } public static long scroll(final String index, final Function<SearchHit, Boolean> callback) { final SearchEngineClient client = ComponentUtil.getSearchEngineClient();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 2.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/backup/ApiAdminBackupAction.java
try (final BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out.stream(), Constants.CHARSET_UTF_8))) { SearchEngineUtil.scroll(index, hit -> { try { writer.write("{\"index\":{\"_index\":\"" + index + "\",\"_id\":\""
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
} return count; } protected void deleteScrollContext(final String scrollId) { if (scrollId != null) { client.prepareClearScroll().addScrollId(scrollId) .execute(wrap(res -> {}, e -> logger.warn("Failed to clear the scroll context.", e))); } }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 84.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
/** The key of the configuration. e.g. */ String API_SEARCH_ACCEPT_REFERERS = "api.search.accept.referers"; /** The key of the configuration. e.g. false */ String API_SEARCH_SCROLL = "api.search.scroll"; /** The key of the configuration. e.g. */ String API_JSON_RESPONSE_HEADERS = "api.json.response.headers"; /** The key of the configuration. e.g. false */
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Apr 11 02:34:53 GMT 2024 - 459.2K bytes - Viewed (4) -
src/main/java/org/codelibs/fess/es/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); } }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/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); } }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
if (logger.isDebugEnabled()) { logger.debug("Failed to process a scroll request.", e); } writeJsonResponse(HttpServletResponse.SC_BAD_REQUEST, e); } catch (final Exception e) { if (logger.isDebugEnabled()) { logger.debug("Failed to process a scroll request.", e); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 02:17:23 GMT 2024 - 50.3K bytes - Viewed (0)