Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 37 for scroll2 (0.04 seconds)

  1. src/test/java/org/codelibs/fess/query/QueryFieldConfigTest.java

            String[] fields = { "scroll1", "scroll2", "scroll3" };
            queryFieldConfig.setScrollResponseFields(fields);
    
            String[] result = queryFieldConfig.getScrollResponseFields();
            assertSame(fields, result);
        }
    
        @Test
        public void test_setScrollResponseFields() {
            String[] fields = { "scroll1", "scroll2", "scroll3" };
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 33.6K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/suggest/util/ScrollOperationHelper.java

                    response = client.prepareSearchScroll(scrollId)
                            .setScroll(settings.getScrollTimeout())
                            .execute()
                            .actionGet(settings.getSearchTimeout());
                    if (!scrollId.equals(response.getScrollId())) {
                        SuggestUtil.deleteScrollContext(client, scrollId);
                    }
                    scrollId = response.getScrollId();
                }
    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)
  3. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java

            when(mockSearchResponse.getScrollId()).thenReturn("scroll1", "scroll1");
            when(mockSearchResponse.getHits()).thenReturn(mockSearchHits);
            when(mockSearchHits.getHits()).thenReturn(new SearchHit[] { mockHit }, new SearchHit[0]);
            when(mockHit.getIndex()).thenReturn("test-index");
            when(mockHit.getId()).thenReturn("doc1");
    
            // Setup scroll response (empty on second call)
    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)
  4. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

                        response = client.prepareSearchScroll(scrollId)
                                .setScroll(settings.getScrollTimeout())
                                .execute()
                                .actionGet(settings.getSearchTimeout());
                        if (!scrollId.equals(response.getScrollId())) {
                            SuggestUtil.deleteScrollContext(client, scrollId);
                        }
                    }
    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)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

            }
            return count;
        }
    
        /**
         * Clears a scroll context.
         *
         * @param scrollId The scroll ID to clear.
         */
        public void clearScroll(final String scrollId) {
            if (scrollId != null) {
                prepareClearScroll().addScrollId(scrollId)
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Nov 23 02:01:26 GMT 2025
    - 26.2K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

         * @param client the OpenSearch client used to clear the scroll context
         * @param scrollId the ID of the scroll context to be deleted; if null, no action is taken
         */
        public static void deleteScrollContext(final Client client, final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(res -> {}, e -> {}));
            }
        }
    
        /**
    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)
  7. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

                deleteScrollContext(scrollId);
            }
            return count;
        }
    
        /**
         * Deletes a scroll context to free resources.
         *
         * @param scrollId the scroll ID to delete
         */
        protected void deleteScrollContext(final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll()
                        .addScrollId(scrollId)
    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)
  8. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

            this.index = index;
        }
    
        /**
         * Gets the scroll timeout in milliseconds.
         *
         * @return The scroll timeout.
         */
        public int getScrollTimeout() {
            return scrollTimeout;
        }
    
        /**
         * Sets the scroll timeout.
         * @param scrollTimeout The scroll timeout.
         */
        public void setScrollTimeout(final int scrollTimeout) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 34.3K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/it/CrawlTestBase.java

                docIds.addAll(resultIds);
                Map<String, Object> scrollBody = new HashMap<>();
                scrollBody.put("scroll", "1m");
                scrollBody.put("scroll_id", scrollId);
                response = given().contentType("application/json").body(scrollBody).get(getEsUrl() + "/_search/scroll");
                jsonPath = JsonPath.from(response.asString());
            }
    
            for (String docId : docIds) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 10.6K bytes
    - Click Count (0)
  10. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

                    }
    
                    final String sid = scrollId;
                    response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
                    if (!scrollId.equals(response.getScrollId())) {
                        getClient().clearScroll(scrollId);
                    }
                    scrollId = response.getScrollId();
                }
            } finally {
    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)
Back to Top