Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for scrollTo (0.27 sec)

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

                    final String sid = scrollId;
                    response = get(c -> c.prepareSearchScroll(sid).setScroll(scrollForDelete).execute());
                    if (!scrollId.equals(response.getScrollId())) {
                        clearScroll(scrollId);
                    }
                    scrollId = response.getScrollId();
                }
            } finally {
                clearScroll(scrollId);
            }
            return count;
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  2. 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: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

            }
            return count;
        }
    
        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)));
            }
        }
    
    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. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

                        response = client.prepareSearchScroll(scrollId).setScroll(settings.getScrollTimeout()).execute()
                                .actionGet(settings.getSearchTimeout());
                        if (!scrollId.equals(response.getScrollId())) {
                            SuggestUtil.deleteScrollContext(client, scrollId);
                        }
                        scrollId = response.getScrollId();
                    }
    Registered: Wed Jun 12 15:38:08 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  5. fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsDataService.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 {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java

                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                    if (!scrollId.equals(response.getScrollId())) {
                        deleteScrollContext(scrollId);
                    }
                    scrollId = response.getScrollId();
                }
            } finally {
                deleteScrollContext(scrollId);
            }
        }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java

                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                    if (!scrollId.equals(response.getScrollId())) {
                        deleteScrollContext(scrollId);
                    }
                    scrollId = response.getScrollId();
                }
            } finally {
                deleteScrollContext(scrollId);
            }
        }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

                    if (!scrollId.equals(response.getScrollId())) {
                        SuggestUtil.deleteScrollContext(client, scrollId);
                    }
                    scrollId = response.getScrollId();
                }
            } finally {
                SuggestUtil.deleteScrollContext(client, scrollId);
            }
    
    Registered: Wed Jun 12 15:38:08 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  9. 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);
                        }
                    }
                    scrollId = response.getScrollId();
    Registered: Wed Jun 12 15:38:08 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java

                    }
                    response = client.prepareSearchScroll(scrollId).setScroll(settings.getScrollTimeout()).execute()
                            .actionGet(settings.getSearchTimeout());
                    if (!scrollId.equals(response.getScrollId())) {
                        SuggestUtil.deleteScrollContext(client, scrollId);
                    }
                    scrollId = response.getScrollId();
                }
            } finally {
    Registered: Wed Jun 12 15:38:08 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top