Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 141 for _shards (0.05 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt

        server.enqueue(MockResponse())
        server.enqueue(MockResponse())
        val request = Request(server.url("/"))
        val response = client.newCall(request).execute()
        response.body.close()
    
        // This client shares a connection pool but has a different SSL socket factory.
        val handshakeCertificates2 = HandshakeCertificates.Builder().build()
        val anotherClient =
          client
            .newBuilder()
            .sslSocketFactory(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 12.2K bytes
    - Viewed (1)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

         */
        public void setBulkBufferSize(final int bulkBufferSize) {
            this.bulkBufferSize = bulkBufferSize;
        }
    
        /**
         * Sets the number of shards for the OpenSearch index.
         *
         * @param numberOfShards The number of shards.
         */
        public void setNumberOfShards(final int numberOfShards) {
            this.numberOfShards = numberOfShards;
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/request/popularwords/PopularWordsRequest.java

                public void onResponse(final SearchResponse searchResponse) {
                    if (searchResponse.getFailedShards() > 0) {
                        deferred.reject(new SuggesterException("Search failure. Failed shards num:" + searchResponse.getFailedShards()));
                    } else {
                        deferred.resolve(createResponse(searchResponse));
                    }
                }
    
                @Override
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2_test.go

    		dataDir          string
    		data             []byte
    		shares           int
    		transitionStatus string
    		restoreObjStatus string
    		expireRestored   bool
    		expectedDataDir  string
    	}{
    		{ // object versions with inlined data don't count towards shared data directory
    			versionID: mustGetUUID(),
    			dataDir:   d0,
    			data:      data,
    			shares:    0,
    		},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbFile.java

     * to referencing files and directories, jCIFS can also address servers,
     * and workgroups.
     * <p>
     * <strong><i>Important: all SMB URLs that represent
     * workgroups, servers, shares, or directories require a trailing slash '/'.
     * </i></strong>
     * <p>
     * When using the {@code java.net.URL} class with
     * 'smb://' URLs it is necessary to first call the static
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 103.2K bytes
    - Viewed (0)
  6. README.md

    - **HTTP/HTTPS**: Full web crawling support with cookies, authentication, redirects
    - **File System**: Local and network file system access
    - **FTP**: FTP server crawling with authentication
    - **SMB/CIFS**: Windows network shares
    - **Storage**: Cloud storage systems (MinIO, S3-compatible)
    
    ### Content Formats
    
    #### Office Documents
    - Microsoft Office (Word, Excel, PowerPoint)
    - OpenOffice/LibreOffice documents
    - RTF, WordPerfect
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SmbFilenameFilter.java

     */
    
    package jcifs.smb1.smb1;
    
    /**
     * Filter interface for SMB filename filtering.
     * This interface allows selective filtering of filenames
     * when listing directory contents in SMB shares.
     */
    public interface SmbFilenameFilter {
        /**
         * Tests whether the specified filename should be included in a file list.
         *
         * @param dir the directory containing the file
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/HashMultimapTest.java

                    CollectionSize.ANY)
                .createTestSuite());
        suite.addTestSuite(HashMultimapTest.class);
        return suite;
      }
    
      /*
       * The behavior of toString() is tested by TreeMultimap, which shares a
       * lot of code with HashMultimap and has deterministic iteration order.
       */
      public void testCreate() {
        HashMultimap<String, Integer> multimap = HashMultimap.create();
        multimap.put("foo", 1);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/collect/HashMultimapTest.java

                    CollectionSize.ANY)
                .createTestSuite());
        suite.addTestSuite(HashMultimapTest.class);
        return suite;
      }
    
      /*
       * The behavior of toString() is tested by TreeMultimap, which shares a
       * lot of code with HashMultimap and has deterministic iteration order.
       */
      public void testCreate() {
        HashMultimap<String, Integer> multimap = HashMultimap.create();
        multimap.put("foo", 1);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java

                public void onResponse(final SearchResponse searchResponse) {
                    if (searchResponse.getFailedShards() > 0) {
                        deferred.reject(new SuggesterException("Search failure. Failed shards num:" + searchResponse.getFailedShards()));
                    } else {
                        deferred.resolve(createResponse(searchResponse));
                    }
                }
    
                @Override
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 17.8K bytes
    - Viewed (0)
Back to top