Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for addScrollId (0.28 seconds)

  1. src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java

                deleteScrollContext(scrollId);
            }
        }
    
        protected void deleteScrollContext(final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {}));
            }
        }
    
        @Override
        protected Number doReadNextVal() {
            final String msg = "This table is NOT related to sequence: " + asEsIndexType();
    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)
  2. src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java

                deleteScrollContext(scrollId);
            }
        }
    
        protected void deleteScrollContext(final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {}));
            }
        }
    
        @Override
        protected Number doReadNextVal() {
            final String msg = "This table is NOT related to sequence: " + asEsIndexType();
    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)
  3. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java

                deleteScrollContext(scrollId);
            }
        }
    
        protected void deleteScrollContext(final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll().addScrollId(scrollId).execute(ActionListener.wrap(() -> {}));
            }
        }
    
        @Override
        protected Number doReadNextVal() {
            final String msg = "This table is NOT related to sequence: " + asEsIndexType();
    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 to delete
         */
        protected void deleteScrollContext(final String scrollId) {
            if (scrollId != null) {
                client.prepareClearScroll()
                        .addScrollId(scrollId)
                        .execute(wrap(res -> {}, e -> logger.warn("Failed to clear the scroll context.", e)));
            }
        }
    
        /**
    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)
Back to Top