Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for _scroll_id (0.08 sec)

  1. 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: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.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: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.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: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/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: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  5. 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: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  6. 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: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  7. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.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: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. 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: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForUpdate).execute()
                            .actionGet(fessConfig.getIndexBulkTimeout());
                    if (!scrollId.equals(response.getScrollId())) {
                        deleteScrollContext(scrollId);
                    }
                    scrollId = response.getScrollId();
                }
            } finally {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Oct 20 02:08:03 UTC 2024
    - 86.1K bytes
    - Viewed (0)
  10. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.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: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 23.6K bytes
    - Viewed (0)
Back to top