Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for prepareClearScroll (0.05 sec)

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

            client.explain(request, listener);
        }
    
        @Override
        public ClearScrollRequestBuilder prepareClearScroll() {
            return client.prepareClearScroll();
        }
    
        @Override
        public ActionFuture<ClearScrollResponse> clearScroll(final ClearScrollRequest request) {
            return client.clearScroll(request);
        }
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 02:01:26 UTC 2025
    - 26.2K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java

            when(mockBulkFuture.actionGet(anyLong(), any(TimeUnit.class))).thenReturn(mockBulkResponse);
            when(mockBulkResponse.hasFailures()).thenReturn(false);
    
            // Setup clear scroll
            when(mockClient.prepareClearScroll()).thenReturn(mockClearScrollBuilder);
            when(mockClearScrollBuilder.addScrollId(any(String.class))).thenReturn(mockClearScrollBuilder);
            doAnswer(invocation -> {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:44:44 UTC 2025
    - 17K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java

            } finally {
                deleteScrollContext(scrollId);
            }
        }
    
        protected void deleteScrollContext(final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {}));
            }
        }
    
        @Override
        protected Number doReadNextVal() {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 27 07:01:25 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java

            } finally {
                deleteScrollContext(scrollId);
            }
        }
    
        protected void deleteScrollContext(final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {}));
            }
        }
    
        @Override
        protected Number doReadNextVal() {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 27 07:01:25 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

         */
        public static void deleteScrollContext(final Client client, final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(res -> {}, e -> {}));
            }
        }
    
        /**
         * Escapes wildcard characters in the given query string.
         *
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Sun Nov 23 11:21:40 UTC 2025
    - 17.5K bytes
    - Viewed (1)
  6. src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java

            } finally {
                deleteScrollContext(scrollId);
            }
        }
    
        protected void deleteScrollContext(final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {}));
            }
        }
    
        @Override
        protected Number doReadNextVal() {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 27 07:01:25 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

        /**
         * Prepares a clear scroll request builder.
         *
         * @return the clear scroll request builder
         */
        @Override
        public ClearScrollRequestBuilder prepareClearScroll() {
            return client.prepareClearScroll();
        }
    
        /**
         * Clears scroll contexts asynchronously.
         *
         * @param request the clear scroll request
         * @return a future for the clear scroll response
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 122.4K bytes
    - Viewed (1)
Back to top