Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for prepareSearchScroll (0.1 sec)

  1. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

                    if (result.hasFailure()) {
                        throw new SuggestIndexException(result.getFailures().get(0));
                    }
    
                    response = client.prepareSearchScroll(scrollId).execute().actionGet(settings.getSearchTimeout());
                    if (!scrollId.equals(response.getScrollId())) {
                        SuggestUtil.deleteScrollContext(client, scrollId);
                    }
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

            client.searchScroll(request, listener);
        }
    
        @Override
        public SearchScrollRequestBuilder prepareSearchScroll(final String scrollId) {
            return client.prepareSearchScroll(scrollId);
        }
    
        @Override
        public ActionFuture<MultiSearchResponse> multiSearch(final MultiSearchRequest request) {
            return client.multiSearch(request);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

                        }
                        response = builder.execute().actionGet(settings.getSearchTimeout());
                    } else {
                        response = client.prepareSearchScroll(scrollId)
                                .setScroll(settings.getScrollTimeout())
                                .execute()
                                .actionGet(settings.getSearchTimeout());
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 11K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

                        }
                        callback.iterate(accessResult);
                    }
    
                    final String sid = scrollId;
                    response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
                    if (!scrollId.equals(response.getScrollId())) {
                        getClient().clearScroll(scrollId);
                    }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java

                        for (final SearchHit hit : hits) {
                            array[count] = hit.getSourceAsMap();
                            count++;
                        }
                        response = client.prepareSearchScroll(scrollId)
                                .setScroll(settings.getScrollTimeout())
                                .execute()
                                .actionGet(settings.getSearchTimeout());
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                        throw new OpenSearchAccessException(bulkResponse.buildFailureMessage());
                    }
    
                    final String sid = scrollId;
                    response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
                    if (!scrollId.equals(response.getScrollId())) {
                        getClient().clearScroll(scrollId);
                    }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java

                                        fieldContentsAnalyzer, fieldContentsReadingAnalyzer));
                    }
                    response = client.prepareSearchScroll(scrollId)
                            .setScroll(settings.getScrollTimeout())
                            .execute()
                            .actionGet(settings.getSearchTimeout());
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

         *
         * @param scrollId the scroll ID
         * @return the search scroll request builder
         */
        @Override
        public SearchScrollRequestBuilder prepareSearchScroll(final String scrollId) {
            return client.prepareSearchScroll(scrollId);
        }
    
        /**
         * Executes a multi-search request asynchronously.
         *
         * @param request the multi-search request
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

                        if (bulkResponse.hasFailures()) {
                            throw new SuggesterException(bulkResponse.buildFailureMessage());
                        }
                        response = client.prepareSearchScroll(scrollId)
                                .setScroll(settings.getScrollTimeout())
                                .execute()
                                .actionGet(settings.getSearchTimeout());
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  10. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

                        throw new OpenSearchAccessException(bulkResponse.buildFailureMessage());
                    }
    
                    final String sid = scrollId;
                    response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
                    if (!scrollId.equals(response.getScrollId())) {
                        getClient().clearScroll(scrollId);
                    }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
Back to top