searchlist - Code Search

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

        try {
            while (scrollId != null) {
                final SearchHits searchHits = getSearchHits(response);
                final SearchHit[] hits = searchHits.getHits();
                if (hits.length == 0) {
                    break;
                }

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

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Nov 27 07:01:25 UTC 2025

- 26.4K bytes

- Viewed (0)

github.com/codelibs/fess

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

        try {
            while (scrollId != null) {
                final SearchHits searchHits = getSearchHits(response);
                final SearchHit[] hits = searchHits.getHits();
                if (hits.length == 0) {
                    break;
                }

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

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Nov 27 07:01:25 UTC 2025

- 26.4K bytes

- Viewed (0)

github.com/codelibs/fess

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

        try {
            while (scrollId != null) {
                final SearchHits searchHits = getSearchHits(response);
                final SearchHit[] hits = searchHits.getHits();
                if (hits.length == 0) {
                    break;
                }

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

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Nov 27 07:01:25 UTC 2025

- 26.4K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

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

                final SearchHits searchHits = response.getHits();
                if (searchHits.getHits().length == 0) {
                    break;
                }

                final BulkResponse bulkResponse = getClient().get(c -> {
                    final BulkRequestBuilder builder = c.prepareBulk();
                    for (final SearchHit searchHit : searchHits) {

Registered: Sat Dec 20 11:21:39 UTC 2025

- Last Modified: Thu Nov 20 08:40:57 UTC 2025

- 16.9K bytes

- Viewed (1)

github.com/codelibs/fess-crawler

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

                final SearchHits searchHits = response.getHits();
                if (searchHits.getHits().length == 0) {
                    break;
                }

                final BulkResponse bulkResponse = getClient().get(c -> {
                    final BulkRequestBuilder bulkBuilder = c.prepareBulk();
                    for (final SearchHit searchHit : searchHits) {

Registered: Sat Dec 20 11:21:39 UTC 2025

- Last Modified: Thu Nov 20 08:40:57 UTC 2025

- 34.3K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

            while (scrollId != null) {
                final SearchHits searchHits = response.getHits();
                final SearchHit[] hits = searchHits.getHits();
                if (hits.length == 0) {
                    break;
                }

                final BulkRequestBuilder bulkRequest = client.prepareBulk();
                for (final SearchHit hit : hits) {

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Fri Nov 28 16:29:12 UTC 2025

- 122.4K bytes

- Viewed (1)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/util/SearchEngineUtil.java

     * @return the number of documents processed
     */
    public static long scroll(final String index, final Function<SearchHit, Boolean> callback) {
        final SearchEngineClient client = ComponentUtil.getSearchEngineClient();
        return client.<SearchHit> scrollSearch(index, searchRequestBuilder -> true, (searchResponse, hit) -> hit,
                hit -> callback.apply(hit));
    }

    /**

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Jul 17 08:28:31 UTC 2025

- 5.1K bytes

- Viewed (0)

github.com/codelibs/fess-suggest

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

            int count = 0;
            try {
                while (scrollId != null) {
                    final SearchHit[] hits = response.getHits().getHits();
                    if (hits.length == 0) {
                        break;
                    }
                    for (final SearchHit hit : hits) {
                        array[count] = hit.getSourceAsMap();
                        count++;
                    }

Registered: Sat Dec 20 13:04:59 UTC 2025

- Last Modified: Mon Nov 24 03:40:05 UTC 2025

- 15.8K bytes

- Viewed (0)

github.com/codelibs/fess-suggest

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

                scrollId = response.getScrollId();
                final SearchHit[] hits = response.getHits().getHits();
                if (scrollId == null || hits.length == 0) {
                    SuggestUtil.deleteScrollContext(client, scrollId);
                    isFinished.set(true);
                }

                for (final SearchHit hit : hits) {
                    final Map<String, Object> source = hit.getSourceAsMap();

Registered: Sat Dec 20 13:04:59 UTC 2025

- Last Modified: Mon Nov 24 03:40:05 UTC 2025

- 11.1K bytes

- Viewed (0)

github.com/codelibs/fess-suggest

src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java

import org.opensearch.index.query.QueryBuilders;
import org.opensearch.index.query.functionscore.FunctionScoreQueryBuilder;
import org.opensearch.index.query.functionscore.ScoreFunctionBuilders;
import org.opensearch.search.SearchHit;
import org.opensearch.search.sort.SortOrder;
import org.opensearch.transport.client.Client;

/**
 * SuggestRequest is a class that handles the request for suggestions.

Registered: Sat Dec 20 13:04:59 UTC 2025

- Last Modified: Thu Aug 07 02:41:28 UTC 2025

- 17.8K bytes

- Viewed (0)

Search Options