Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 204 for Collector (0.24 sec)

  1. src/main/java/org/codelibs/fess/crawler/transformer/AbstractFessFileTransformer.java

    import java.io.InputStream;
    import java.net.URLDecoder;
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    
    import org.apache.commons.lang3.StringUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.misc.Tuple3;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  2. docs/smb3-features/04-directory-leasing-design.md

        
        public List<SmbFile> batchExists(List<String> paths) {
            // Group paths by parent directory
            Map<String, List<String>> pathsByParent = paths.stream()
                .collect(Collectors.groupingBy(this::getParentPath));
            
            List<SmbFile> results = new ArrayList<>();
            
            for (Map.Entry<String, List<String>> entry : pathsByParent.entrySet()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.commons.lang3.StringUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.concurrent.CommonPoolUtil;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 26.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.apache.lucene.search.TotalHits.Relation;
    import org.codelibs.core.collection.ArrayUtil;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/exec/Crawler.java

    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.CoreLibConstants;
    import org.codelibs.core.exception.InterruptedRuntimeException;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 31K bytes
    - Viewed (0)
  6. src/test/java/jcifs/SmbSessionTest.java

                java.util.Set<String> methodNames =
                        java.util.Arrays.stream(methods).map(java.lang.reflect.Method::getName).collect(java.util.stream.Collectors.toSet());
    
                assertTrue(methodNames.contains("close"), "Should contain close method");
                assertTrue(methodNames.contains("getConfig"), "Should contain getConfig method");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/ds/DataStoreFactoryTest.java

                protected List<String> loadDataStoreNameList() {
                    // Return unsorted list to test sorting
                    return List.of("Zebra", "Apple", "Banana").stream().sorted().collect(java.util.stream.Collectors.toList());
                }
            };
    
            List<String> names = testFactory.loadDataStoreNameList();
            assertEquals(3, names.size());
            assertEquals("Apple", names.get(0));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  8. guava-testlib/test/com/google/common/testing/ClassSanityTesterTest.java

    import java.util.AbstractList;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Unit tests for {@link ClassSanityTester}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/SearchHelper.java

    import java.util.Locale;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.concurrent.ExecutionException;
    import java.util.function.Consumer;
    import java.util.stream.Collectors;
    import java.util.zip.GZIPInputStream;
    import java.util.zip.GZIPOutputStream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.exception.IORuntimeException;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 35.8K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/opensearch/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: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
Back to top