Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for prepareSearchScroll (0.12 sec)

  2. github.com/codelibs/fess-crawler

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

            client.searchScroll(request, listener);
    }

    @Override
    public SearchScrollRequestBuilder prepareSearchScroll(final String scrollId) {
        return client.prepareSearchScroll(scrollId);
    }

    @Override
    public ActionFuture<MultiSearchResponse> multiSearch(final MultiSearchRequest request) {
        return client.multiSearch(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)
  3. github.com/codelibs/fess

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

                        break;
                }

                if (!handler.apply(searchHits)) {
                    break;
                }

                response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                if (!scrollId.equals(response.getScrollId())) {
                    deleteScrollContext(scrollId);
                }
    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. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java 

                        break;
                }

                if (!handler.apply(searchHits)) {
                    break;
                }

                response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                if (!scrollId.equals(response.getScrollId())) {
                    deleteScrollContext(scrollId);
                }
    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. github.com/codelibs/fess-crawler

    fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java 

                        }
                    callback.iterate(accessResult);
                }

                final String sid = scrollId;
                response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
                if (!scrollId.equals(response.getScrollId())) {
                    getClient().clearScroll(scrollId);
                }
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  6. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java 

                        break;
                }

                if (!handler.apply(searchHits)) {
                    break;
                }

                response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                if (!scrollId.equals(response.getScrollId())) {
                    deleteScrollContext(scrollId);
                }
    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. github.com/codelibs/fess-suggest

    src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java 

                        }
                    response = builder.execute().actionGet(settings.getSearchTimeout());
                } else {
                    response = client.prepareSearchScroll(scrollId)
                            .setScroll(settings.getScrollTimeout())
                            .execute()
                            .actionGet(settings.getSearchTimeout());
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  8. github.com/codelibs/fess-suggest

    src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java 

                        for (final SearchHit hit : hits) {
                        array[count] = hit.getSourceAsMap();
                        count++;
                    }
                    response = client.prepareSearchScroll(scrollId)
                            .setScroll(settings.getScrollTimeout())
                            .execute()
                            .actionGet(settings.getSearchTimeout());
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  9. github.com/codelibs/fess-crawler

    fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java 

            when(mockHit.getIndex()).thenReturn("test-index");
        when(mockHit.getId()).thenReturn("doc1");

        // Setup scroll response (empty on second call)
        when(mockClient.prepareSearchScroll("scroll1")).thenReturn(mockScrollBuilder);
        when(mockScrollBuilder.setScroll(any(Scroll.class))).thenReturn(mockScrollBuilder);
        when(mockScrollBuilder.execute()).thenReturn(mockScrollFuture);
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:44:44 UTC 2025
    - 17K bytes
    - Viewed (0)
  10. github.com/codelibs/fess-crawler

    fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java 

                        throw new OpenSearchAccessException(bulkResponse.buildFailureMessage());
                }

                final String sid = scrollId;
                response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
                if (!scrollId.equals(response.getScrollId())) {
                    getClient().clearScroll(scrollId);
                }
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 16.9K bytes
    - Viewed (1)
  11. github.com/codelibs/fess-suggest

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

                    if (result.hasFailure()) {
                    throw new SuggestIndexException(result.getFailures().get(0));
                }

                response = client.prepareSearchScroll(scrollId).execute().actionGet(settings.getSearchTimeout());
                if (!scrollId.equals(response.getScrollId())) {
                    SuggestUtil.deleteScrollContext(client, scrollId);
                }
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 34.4K bytes
    - Viewed (0)
Back to top