Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 14 of 14 for getScroll (0.27 sec)

  1. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

            }
    
            final List<SuggestItem> updateItems = new ArrayList<>();
            SearchResponse response = client.prepareSearch(index).setSize(500).setScroll(settings.getScrollTimeout())
                    .setQuery(QueryBuilders.rangeQuery(FieldNames.DOC_FREQ).gte(1)).execute().actionGet(settings.getSearchTimeout());
            String scrollId = response.getScrollId();
            try {
    Registered: Wed Jun 12 15:38:08 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. fess-crawler-es/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

            return this;
        }
    
        public int deleteByQuery(final String index, final String type, final QueryBuilder queryBuilder) {
            SearchResponse response =
                    get(c -> c.prepareSearch(index).setScroll(scrollForDelete).setSize(sizeForDelete).setQuery(queryBuilder).execute());
            String scrollId = response.getScrollId();
            int count = 0;
            try {
                while (scrollId != null) {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            SearchResponse response = option.apply(client.prepareSearch(index).setScroll(scrollForUpdate).setSize(sizeForUpdate)
                    .setPreference(Constants.SEARCH_PREFERENCE_LOCAL)).execute().actionGet(fessConfig.getIndexScrollSearchTimeout());
    
            int count = 0;
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 84.1K bytes
    - Viewed (0)
  4. fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

        }
    
        public void delete(final Consumer<SearchRequestBuilder> callback) {
            SearchResponse response = getClient().get(c -> {
                final SearchRequestBuilder builder = c.prepareSearch(index).setScroll(new TimeValue(scrollTimeout)).setSize(scrollSize);
                callback.accept(builder);
                return builder.execute();
            });
            String scrollId = response.getScrollId();
            try {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Apr 04 09:58:36 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top