Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for scroll (0.1 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

        /**
         * Clears a scroll context.
         *
         * @param scrollId The scroll ID to clear.
         */
        public void clearScroll(final String scrollId) {
            if (scrollId != null) {
                prepareClearScroll().addScrollId(scrollId)
                        .execute(ActionListener.wrap(res -> {}, e -> logger.warn("Failed to clear " + scrollId, e)));
            }
        }
    
        /**
         * Listener for connection events.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  2. 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)
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

            return queue.poll();
        }
    
        @Override
        public void close() {
            isFinished.set(true);
            queue.clear();
        }
    
        /**
         * Sets the scroll size.
         * @param scrollSize The scroll size.
         */
        public void setScrollSize(final int scrollSize) {
            this.scrollSize = scrollSize;
        }
    
        /**
         * Sets the limit of document size.
    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/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) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  5. 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 -> {}));
            }
        }
    
        /**
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  6. 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) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SearchHelper.java

     *
     * This class provides comprehensive search functionality including document search,
     * scroll search, and bulk operations. It handles search request parameter processing,
     * query building, response formatting, and search log management.
     *
     * Key features:
     * - Document search with pagination and faceting
     * - Scroll search for large result sets
     * - Document retrieval by ID
     * - Bulk document updates
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 35.8K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/settings/SuggestSettings.java

         * @return A SuggestSettingsBuilder instance.
         */
        public static SuggestSettingsBuilder builder() {
            return new SuggestSettingsBuilder();
        }
    
        /**
         * Returns the scroll timeout.
         * @return The scroll timeout.
         */
        public String getScrollTimeout() {
            return timeoutSettings.scrollTimeout;
        }
    
        /**
         * Returns the search timeout.
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/suggest/settings/SuggestSettingsBuilderTest.java

        }
    
        @Test
        public void testScrollTimeout() {
            // Test setting scroll timeout
            SuggestSettingsBuilder result = builder.scrollTimeout("10s");
            assertEquals(builder, result); // Test method chaining
            assertEquals("10s", builder.timeoutSettings.scrollTimeout);
    
            // Test updating scroll timeout
            builder.scrollTimeout("30s");
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to process a scroll request.", e);
                }
                writeJsonResponse(HttpServletResponse.SC_BAD_REQUEST, e);
            } catch (final Exception e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to process a scroll request.", e);
                }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 54.6K bytes
    - Viewed (1)
Back to top