- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for scrollTimeout (0.08 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
} public void setIndex(final String index) { this.index = index; } public int getScrollTimeout() { return scrollTimeout; } public void setScrollTimeout(final int scrollTimeout) { this.scrollTimeout = scrollTimeout; } public int getScrollSize() { return scrollSize; } public void setScrollSize(final int scrollSize) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java
@Override public void iterate(final String sessionId, final AccessResultCallback<OpenSearchAccessResult> callback) { SearchResponse response = getClient().get(c -> c.prepareSearch(index).setScroll(new TimeValue(scrollTimeout)) .setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, sessionId))).setSize(scrollSize).execute()); String scrollId = response.getScrollId(); try {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 8.5K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
} @Override public void updateSessionId(final String oldSessionId, final String newSessionId) { SearchResponse response = getClient().get(c -> c.prepareSearch(index).setScroll(new TimeValue(scrollTimeout)) .setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, oldSessionId))).setSize(scrollSize) .execute()); String scrollId = response.getScrollId();
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0)