- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for setScroll (0.06 sec)
-
src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java
}); } protected void delegateBulkRequest(final ConditionBean cb, Function<SearchHits, Boolean> handler) { final SearchRequestBuilder builder = client.prepareSearch(asEsIndex()).setScroll(scrollForCursor).setSize(sizeForCursor); final EsAbstractConditionBean esCb = (EsAbstractConditionBean) cb; if (esCb.getPreference() != null) { builder.setPreference(esCb.getPreference());
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jun 21 04:02:44 UTC 2025 - 26.4K 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());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 10.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
if (scrollId == null) { final SearchRequestBuilder builder = client.prepareSearch() .setIndices(indexName) .setScroll(settings.getScrollTimeout()) .setQuery(queryBuilder) .setSize(scrollSize); for (final SortBuilder<?> sortBuilder : sortList) {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 11K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java
}); } protected void delegateBulkRequest(final ConditionBean cb, Function<SearchHits, Boolean> handler) { final SearchRequestBuilder builder = client.prepareSearch(asEsIndex()).setScroll(scrollForCursor).setSize(sizeForCursor); final EsAbstractConditionBean esCb = (EsAbstractConditionBean) cb; if (esCb.getPreference() != null) { builder.setPreference(esCb.getPreference());
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jun 21 04:02:44 UTC 2025 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java
}); } protected void delegateBulkRequest(final ConditionBean cb, Function<SearchHits, Boolean> handler) { final SearchRequestBuilder builder = client.prepareSearch(asEsIndex()).setScroll(scrollForCursor).setSize(sizeForCursor); final EsAbstractConditionBean esCb = (EsAbstractConditionBean) cb; if (esCb.getPreference() != null) { builder.setPreference(esCb.getPreference());
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jun 21 04:02:44 UTC 2025 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java
final String actualIndex = index + "." + type.toLowerCase(Locale.ENGLISH); try { SearchResponse response = client.prepareSearch() .setIndices(actualIndex) .setScroll(settings.getScrollTimeout()) .setQuery(QueryBuilders.termQuery(FieldNames.ARRAY_KEY, key)) .setSize(500) .execute()
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 15.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
} final List<SuggestItem> updateItems = new ArrayList<>(); SearchResponse response = client.prepareSearch(index) .setSize(500) .setScroll(settings.getScrollTimeout()) .setQuery(QueryBuilders.rangeQuery(FieldNames.DOC_FREQ).gte(1)) .execute() .actionGet(settings.getSearchTimeout());
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 34.8K 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());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java
SearchResponse response = client.prepareSearch(analyzerSettingsIndexName) .setQuery(QueryBuilders.termQuery(FieldNames.ANALYZER_SETTINGS_TYPE, FIELD_ANALYZER_MAPPING)) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout()); String scrollId = response.getScrollId(); try { while (scrollId != null) {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 26.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
try { SearchResponse response = client.prepareSearch(index) .setQuery(queryBuilder) .setSize(500) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout()); String scrollId = response.getScrollId(); try {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Mon Sep 01 13:33:03 UTC 2025 - 17.4K bytes - Viewed (0)