Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for foreach (0.04 sec)

  1. src/main/java/org/codelibs/fess/suggest/Suggester.java

                    getAliasesResponse.getAliases()
                            .entrySet()
                            .forEach(x -> x.getValue()
                                    .stream()
                                    .filter(y -> updateAlias.equals(y.alias()))
                                    .forEach(y -> updateIndices.add(x.getKey())));
                }
                if (updateIndices.size() != 1) {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 20.7K bytes
    - Viewed (3)
  2. src/main/java/org/codelibs/fess/suggest/converter/KatakanaToAlphabetConverter.java

            return map;
        }
    
        private List<StringBuilder> deepCopyBufList(final List<StringBuilder> bufList) {
            final List<StringBuilder> list = new ArrayList<>();
            bufList.forEach(buf -> list.add(new StringBuilder(buf.toString())));
            return list;
        }
    
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  3. README.md

        .setQuery("sea")                    // user input
        .setSize(10)                        // max suggestions
        .execute()
        .getResponse();
    
    // Process suggestions
    response.getItems().forEach(item -> {
        System.out.println("Suggestion: " + item.getText()[0]);
        System.out.println("Score: " + item.getScore());
    });
    ```
    
    #### 4. Asynchronous Suggestions
    
    ```java
    suggester.suggest()
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Sun Aug 31 03:31:14 UTC 2025
    - 12.1K bytes
    - Viewed (1)
  4. src/main/java/org/codelibs/fess/suggest/settings/SuggestSettings.java

                final Map<String, Object> defaultSettings = defaultSettings();
                initialSettings.forEach((key, value) -> {
                    if (value instanceof Collection) {
                        @SuppressWarnings("unchecked")
                        final Collection<Object> collection = (Collection<Object>) value;
                        collection.forEach(element -> arraySettings.add(new Tuple<>(key, element)));
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

        }
    
        /**
         * Destroys the service.
         */
        @PreDestroy
        public void destroy() {
            sessionCache.entrySet().stream().map(e -> e.getValue().waitingQueue).forEach(q -> q.forEach(urlQueue -> {
                try {
                    insert(urlQueue);
                } catch (final Exception e) {
                    logger.warn("Failed to restore " + urlQueue, e);
                }
            }));
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (1)
  6. src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java

            }
    
            if (filterList.size() > 0) {
                final BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
                boolQueryBuilder.must(queryBuilder);
                filterList.forEach(boolQueryBuilder::filter);
                builder.setQuery(boolQueryBuilder);
            } else {
                builder.setQuery(queryBuilder);
            }
    
            builder.execute(new ActionListener<SearchResponse>() {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java

                responseData.setLastModified(statObject.lastModified() == null ? null : Date.from(statObject.lastModified().toInstant()));
                responseData.setMimeType(statObject.contentType());
                statObject.headers().forEach(e -> responseData.addMetaData(e.getFirst(), e.getSecond()));
    
                if (contentLengthHelper != null) {
                    final long maxLength = contentLengthHelper.getMaxLength(responseData.getMimeType());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17.9K bytes
    - Viewed (2)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/form/FormScheme.java

                    }
                    buf.append(loginReqParams);
                    if (!responseParams.isEmpty()) {
                        buf.append('&');
                        responseParams.stream().forEach(p -> {
                            try {
                                buf.append(URLEncoder.encode(p.getFirst(), encoding));
                                buf.append('=');
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14.3K bytes
    - Viewed (1)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java

            }
    
            super.init();
    
            final Properties props = new Properties();
            System.getProperties().entrySet().stream().filter(e -> e.getKey().toString().startsWith("jcifs.")).forEach(e -> {
                props.setProperty((String) e.getKey(), (String) e.getValue());
            });
            try {
                cifsContext = new BaseContext(new PropertyConfiguration(props));
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 22.5K bytes
    - Viewed (3)
  10. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

                            break;
                        }
    
                        final BulkRequestBuilder bulkRequestBuiler = client.prepareBulk();
                        Stream.of(hits).map(SearchHit::getId).forEach(id -> bulkRequestBuiler.add(new DeleteRequest(index, id)));
    
                        final BulkResponse bulkResponse = bulkRequestBuiler.execute().actionGet(settings.getBulkTimeout());
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 17.4K bytes
    - Viewed (0)
Back to top