Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for prepareSearchScroll (0.11 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 Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K 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 Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  3. 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());
                        if (!scrollId.equals(response.getScrollId())) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java

                        break;
                    }
    
                    if (!handler.apply(searchHits)) {
                        break;
                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                    if (!scrollId.equals(response.getScrollId())) {
                        deleteScrollContext(scrollId);
                    }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  5. 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 Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java

                        break;
                    }
    
                    if (!handler.apply(searchHits)) {
                        break;
                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                    if (!scrollId.equals(response.getScrollId())) {
                        deleteScrollContext(scrollId);
                    }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java

                        break;
                    }
    
                    if (!handler.apply(searchHits)) {
                        break;
                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                    if (!scrollId.equals(response.getScrollId())) {
                        deleteScrollContext(scrollId);
                    }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  8. 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());
                        if (!scrollId.equals(response.getScrollId())) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java

                                        fieldContentsAnalyzer, fieldContentsReadingAnalyzer));
                    }
                    response = client.prepareSearchScroll(scrollId).setScroll(settings.getScrollTimeout()).execute()
                            .actionGet(settings.getSearchTimeout());
                    if (!scrollId.equals(response.getScrollId())) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 19.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 Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 23.6K bytes
    - Viewed (0)
Back to top