Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1171 - 1180 of 1,315 for _size (0.02 sec)

  1. android/guava/src/com/google/common/hash/BloomFilter.java

       * filters to be compatible, they must:
       *
       * <ul>
       *   <li>not be the same instance
       *   <li>have the same number of hash functions
       *   <li>have the same bit size
       *   <li>have the same strategy
       *   <li>have equal funnels
       * </ul>
       *
       * @param that The Bloom filter to check for compatibility.
       * @since 15.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  2. impl/maven-core/src/main/java/org/apache/maven/bridge/MavenRepositorySystem.java

                List<ArtifactRepository> mirroredRepos = new ArrayList<>();
    
                List<ArtifactRepositoryPolicy> releasePolicies = new ArrayList<>(aliasedRepos.size());
    
                for (ArtifactRepository aliasedRepo : aliasedRepos) {
                    releasePolicies.add(aliasedRepo.getReleases());
                    mirroredRepos.addAll(aliasedRepo.getMirroredRepositories());
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/cache/CacheBuilderSpecTest.java

        Object value = new Object();
        LoadingCache<Object, Object> cache =
            builder.build(CacheLoader.from(Suppliers.ofInstance(value)));
        assertSame(value, cache.getUnchecked(key));
        assertEquals(0, cache.size());
        assertFalse(cache.asMap().containsKey(key));
      }
    
      public void testCacheBuilderFrom_string() {
        CacheBuilder<?, ?> fromString =
            CacheBuilder.from(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  4. internal/event/target/kafka.go

    		}
    	}
    	if k.BatchCommitTimeout > 0 {
    		if k.QueueDir == "" || k.BatchSize <= 1 {
    			return errors.New("batch commit timeout should be set only if queue dir is enabled and batch size > 1")
    		}
    	}
    	return nil
    }
    
    // KafkaTarget - Kafka target.
    type KafkaTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       KafkaArgs
    	client     sarama.Client
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

            call.cancel()
          } else {
            threadToCancel!!.interrupt()
          }
          latch.countDown()
        }.apply { start() }
        return latch
      }
    
      companion object {
        // The size of the socket buffers in bytes.
        private const val SOCKET_BUFFER_SIZE = 256 * 1024
      }
    }
    
    class CancelModelParamProvider : SimpleProvider() {
      override fun arguments() =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/graph/ImmutableValueGraph.java

    public final class ImmutableValueGraph<N, V> extends StandardValueGraph<N, V> {
    
      private ImmutableValueGraph(ValueGraph<N, V> graph) {
        super(ValueGraphBuilder.from(graph), getNodeConnections(graph), graph.edges().size());
      }
    
      /** Returns an immutable copy of {@code graph}. */
      public static <N, V> ImmutableValueGraph<N, V> copyOf(ValueGraph<N, V> graph) {
        return (graph instanceof ImmutableValueGraph)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 01 16:30:37 UTC 2022
    - 7.7K bytes
    - Viewed (0)
  7. internal/s3select/json/preader.go

    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    	// Read until next line.
    	in, err := r.buf.ReadBytes('\n')
    	dst = append(dst, in...)
    	return dst, err
    }
    
    // jsonSplitSize is the size of each block.
    // Blocks will read this much and find the first following newline.
    // 128KB appears to be a very reasonable default.
    const jsonSplitSize = 128 << 10
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/TreeMultiset.java

          return aggr.treeAggregate(node.right)
              + aggr.nodeAggregate(node)
              + aggregateAboveRange(aggr, node.left);
        }
      }
    
      @Override
      public int size() {
        return Ints.saturatedCast(aggregateForEntries(Aggregate.SIZE));
      }
    
      @Override
      int distinctElements() {
        return Ints.saturatedCast(aggregateForEntries(Aggregate.DISTINCT));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         * method was called and when all the listeners were installed.
         */
        ServiceManagerState(ImmutableCollection<Service> services) {
          this.numberOfServices = services.size();
          servicesByState.putAll(NEW, services);
        }
    
        /**
         * Attempts to start the timer immediately prior to the service being started via {@link
         * Service#startAsync()}.
         */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/ServiceManager.java

         * method was called and when all the listeners were installed.
         */
        ServiceManagerState(ImmutableCollection<Service> services) {
          this.numberOfServices = services.size();
          servicesByState.putAll(NEW, services);
        }
    
        /**
         * Attempts to start the timer immediately prior to the service being started via {@link
         * Service#startAsync()}.
         */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
Back to top