Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 375 for jstream (0.14 sec)

  1. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

            final Map<String, UserInfo> userInfoMap = new HashMap<>();
            queue.stream().forEach(searchLog -> {
                final String userAgent = searchLog.getUserAgent();
                final boolean isBot =
                        userAgent != null && stream(botNames).get(stream -> stream.anyMatch(botName -> userAgent.indexOf(botName) >= 0));
                if (!isBot) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Mon Jul 22 02:07:37 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/ThemeHelper.java

    import java.nio.file.StandardCopyOption;
    import java.util.Comparator;
    import java.util.stream.Stream;
    import java.util.zip.ZipEntry;
    import java.util.zip.ZipInputStream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.stream.StreamUtil;
    import org.codelibs.fess.exception.ThemeException;
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/query/QueryCommand.java

            }
            final float importantContantLangBoost = fessConfig.getQueryBoostImportantContentLangAsDecimal().floatValue();
            getQueryLanguages().ifPresent(langs -> stream(langs).of(stream -> stream.forEach(lang -> {
                defaultQuery.add(
                        builder.apply(fessConfig.getIndexFieldTitle() + "_" + lang, fessConfig.getQueryBoostTitleLangAsDecimal().floatValue()));
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/client/CrawlerEngineClient.java

        @Override
        protected Client createClient() {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final String[] hosts =
                    split(address, ",").get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n]));
            final Builder builder = Settings.builder().putList("http.hosts", hosts).put("processors", fessConfig.getCrawlerHttpProcessors())
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    				// We are not starting at the beginning, so ignore stream identifiers.
    				dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier())
    			}
    			s2Reader := s2.NewReader(inputReader, dopts...)
    			// Apply the skipLen and limit on the decompressed stream.
    			if decOff > 0 {
    				if err = s2Reader.Skip(decOff); err != nil {
    					// Call the cleanup funcs
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/job/ExecJob.java

            System.getProperties().keySet().stream().filter(k -> k != null && k.toString().startsWith(Constants.FESS_CONFIG_PREFIX))
                    .forEach(k -> addSystemProperty(cmdList, k.toString(), null, null));
        }
    
        protected void addFessSystemProperties(final List<String> cmdList) {
            System.getProperties().keySet().stream().filter(k -> k != null && k.toString().startsWith(Constants.SYSTEM_PROP_PREFIX))
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

                        logger.debug(() -> "Refreshed " + stream(indices).get(stream -> stream.collect(Collectors.joining(", "))));
                    }
                }
    
                @Override
                public void onFailure(final Exception e) {
                    logger.error(() -> "Failed to refresh " + stream(indices).get(stream -> stream.collect(Collectors.joining(", "))), e);
                }
            });
    
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sun Oct 20 02:08:03 UTC 2024
    - 86.1K bytes
    - Viewed (0)
  8. docs/debugging/inspect/decrypt-v1.go

    	if want != got {
    		return fmt.Errorf("Invalid key checksum, want %x, got %x", want, got)
    	}
    
    	stream, err := sio.AES_256_GCM.Stream(key)
    	if err != nil {
    		return err
    	}
    	// Zero nonce, we only use each key once, and 32 bytes is plenty.
    	nonce := make([]byte, stream.NonceSize())
    	encr := stream.DecryptReader(r, nonce, nil)
    	_, err = io.Copy(w, encr)
    	if err == nil {
    		fmt.Println(okMsg)
    	}
    	return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 11 21:22:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/LabelTypeHelper.java

     */
    package org.codelibs.fess.helper;
    
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Set;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/RoleQueryHelper.java

        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            stream(ComponentUtil.getFessConfig().getSearchDefaultPermissionsAsArray()).of(stream -> stream.forEach(name -> {
                defaultRoleList.add(name);
            }));
        }
    
        public Set<String> build(final SearchRequestType searchRequestType) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Jul 25 01:48:41 UTC 2024
    - 11.5K bytes
    - Viewed (0)
Back to top