Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 250 for asStream (0.04 seconds)

  1. src/main/java/org/codelibs/fess/util/JvmUtil.java

         */
        public static String[] filterJvmOptions(final String[] values) {
            final int version = getJavaVersion();
            return Arrays.stream(values).map(s -> {
                final Matcher matcher = VERSION_PREFIX_PATTERN.matcher(s);
                if (!matcher.matches()) {
                    return s;
                }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/job/IndexExportJob.java

    import java.security.MessageDigest;
    import java.security.NoSuchAlgorithmException;
    import java.util.Arrays;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.atomic.AtomicLong;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.mylasta.direction.FessConfig;
    import org.codelibs.fess.opensearch.client.SearchEngineClient;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 10.8K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/crawler/helper/FessMimeTypeHelperTest.java

                    return ".sql=text/x-sql";
                }
            });
    
            mimeTypeHelper.init();
    
            // Override works even without an input stream
            assertEquals("text/x-sql", mimeTypeHelper.getContentType(null, "test.sql"));
        }
    
        @Test
        public void test_getContentType_overridePriority() throws IOException {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Jan 24 09:06:33 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/it/admin/DocumentsTests.java

            // Verify document content
            for (int i = 0; i < 5; i++) {
                final String expectedTitle = NAME_PREFIX + i;
                boolean found = docs.stream().anyMatch(doc -> expectedTitle.equals(doc.get("title")));
                assertTrue(found, "Document with title " + expectedTitle + " should exist");
            }
    
            logger.info("[END] testBulkCreate");
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 9.9K bytes
    - Click Count (0)
  5. build-logic/buildquality/src/test/kotlin/gradlebuild/testcleanup/TestFilesCleanupServiceTest.kt

            Caused by: java.io.IOException: Failed to delete temp directory /var/folders/_2/vxp7qn2x7qzd0zqqm8p128lh0000gq/T/junit-4205933054320696172.
    	        at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
             */
            .withDebug(true)
            .withArguments(*args, "--stacktrace", "--no-watch-fs")
    
        private
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Feb 10 00:16:44 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/reqheader/ApiAdminReqheaderAction.java

     */
    package org.codelibs.fess.app.web.api.admin.reqheader;
    
    import static org.codelibs.fess.app.web.admin.reqheader.AdminReqheaderAction.getRequestHeader;
    
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.ReqHeaderPager;
    import org.codelibs.fess.app.service.RequestHeaderService;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/api/admin/webauth/ApiAdminWebauthAction.java

     */
    package org.codelibs.fess.app.web.api.admin.webauth;
    
    import static org.codelibs.fess.app.web.admin.webauth.AdminWebauthAction.getWebAuthentication;
    
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.WebAuthPager;
    import org.codelibs.fess.app.service.WebAuthenticationService;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  8. .teamcity/scripts/FindCommits.java

    import java.io.IOException;
    import java.io.InputStream;
    import java.nio.charset.StandardCharsets;
    import java.util.Arrays;
    import java.util.List;
    import java.util.Objects;
    import java.util.stream.Collectors;
    
    /**
     * TeamCity helper script that prints the list of commits in the current PR (one SHA per line).
     *
     * Usage (Java 11+ single-file source execution):
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Jan 20 03:53:25 GMT 2026
    - 5.5K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java

         */
        public String getSimpleName() {
            return new File(path).getName();
        }
    
        /**
         * Updates the dictionary file with the given input stream.
         *
         * @param in The input stream.
         * @throws IOException If an I/O error occurs.
         */
        public synchronized void update(final InputStream in) throws IOException {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 07:09:00 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/util/ErrorToWarnRewritePolicy.java

         */
        @PluginFactory
        public static ErrorToWarnRewritePolicy createPolicy(@PluginAttribute("loggers") final String loggerNamePrefix) {
            final String[] loggerNames = loggerNamePrefix != null
                    ? Arrays.stream(loggerNamePrefix.split(",")).map(String::trim).filter(s -> s.length() > 0).toArray(n -> new String[n])
                    : new String[0];
            return new ErrorToWarnRewritePolicy(loggerNames);
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 3.4K bytes
    - Click Count (0)
Back to Top