Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 11 for prepareSearchScroll (0.12 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/org/codelibs/fess/suggest/util/ScrollOperationHelper.java

                        break;
                    }
                    for (final SearchHit hit : hits) {
                        processor.process(hit, results);
                    }
                    response = client.prepareSearchScroll(scrollId)
                            .setScroll(settings.getScrollTimeout())
                            .execute()
                            .actionGet(settings.getSearchTimeout());
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 9.7K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/suggest/index/operations/DeletionOperations.java

                    if (result.hasFailure()) {
                        throw new SuggestIndexException(result.getFailures().get(0));
                    }
                    updateItems.clear();
    
                    response = client.prepareSearchScroll(scrollId).execute().actionGet(settings.getSearchTimeout());
                    if (!scrollId.equals(response.getScrollId())) {
                        SuggestUtil.deleteScrollContext(client, scrollId);
                    }
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 9.5K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/opensearch/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);
                    }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 27 07:01:25 GMT 2025
    - 26.4K bytes
    - Click Count (0)
  4. 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
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 138.6K bytes
    - Click Count (1)
  5. 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);
                    }
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  6. 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());
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Mon Nov 24 03:40:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/opensearch/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);
                    }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 27 07:01:25 GMT 2025
    - 26.4K bytes
    - Click Count (0)
  8. 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());
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Mon Nov 24 03:40:05 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  9. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java

            when(mockHit.getIndex()).thenReturn("test-index");
            when(mockHit.getId()).thenReturn("doc1");
    
            // Setup scroll response (empty on second call)
            when(mockClient.prepareSearchScroll("scroll1")).thenReturn(mockScrollBuilder);
            when(mockScrollBuilder.setScroll(any(Scroll.class))).thenReturn(mockScrollBuilder);
            when(mockScrollBuilder.execute()).thenReturn(mockScrollFuture);
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Mon Jan 12 06:25:38 GMT 2026
    - 16.9K bytes
    - Click Count (0)
  10. 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());
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Nov 23 11:21:40 GMT 2025
    - 17.5K bytes
    - Click Count (1)
Back to Top