Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for setScroll (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top