Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 133 for _producer (0.29 seconds)

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

     *       (given by {@link #bits}). For example, {@link Hashing#sha1} produces a 160-bit number,
     *       while {@link Hashing#murmur3_32()} yields only 32 bits. Because a {@code long} value is
     *       clearly insufficient to hold all hash code values, this API represents a hash code as an
     *       instance of {@link HashCode}.
     *   <li><b>pure function:</b> the value produced must depend only on the input bytes, in the order
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  2. src/test/java/jcifs/smb1/util/HMACT64Test.java

                    different = true;
                    break;
                }
            }
            assertEquals(true, different, "Different keys should produce different HMAC values");
        }
    
        @Test
        void testDifferentDataProducesDifferentResults() {
            // Test that different data produces different results
            byte[] data1 = "data1".getBytes();
            byte[] data2 = "data2".getBytes();
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/hash/Hashing.java

       *
       * @param minimumBits a positive integer. This can be arbitrarily large. The returned {@link
       *     HashFunction} instance may use memory proportional to this integer.
       * @return a hash function, described above, that produces hash codes of length {@code
       *     minimumBits} or greater
       */
      public static HashFunction goodFastHash(int minimumBits) {
        int bits = checkPositiveAndMakeMultipleOf32(minimumBits);
    
        if (bits == 32) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 29.8K bytes
    - Click Count (0)
  4. tensorflow/c/eager/c_api.h

    // This function will block till the operation that produces `h` has completed.
    TF_CAPI_EXPORT extern int64_t TFE_TensorHandleDim(TFE_TensorHandle* h,
                                                      int dim_index,
                                                      TF_Status* status);
    
    // Returns the device of the operation that produced `h`. If `h` was produced by
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Apr 27 21:07:00 GMT 2023
    - 22.8K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/FluentIterable.java

       * stream.collect(ImmutableListMultimap.toImmutableListMultimap(keyFunction, v -> v))}.
       *
       * @param keyFunction the function used to produce the key for each value
       * @throws NullPointerException if any element of this iterable is {@code null}, or if {@code
       *     keyFunction} produces {@code null} for any key
       * @since 14.0
       */
      @SuppressWarnings("nullness") // Unsafe, but we can't do much about it now.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/FluentIterable.java

       * stream.collect(ImmutableListMultimap.toImmutableListMultimap(keyFunction, v -> v))}.
       *
       * @param keyFunction the function used to produce the key for each value
       * @throws NullPointerException if any element of this iterable is {@code null}, or if {@code
       *     keyFunction} produces {@code null} for any key
       * @since 14.0
       */
      @SuppressWarnings("nullness") // Unsafe, but we can't do much about it now.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  7. internal/logger/target/kafka/kafka.go

    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	sconfig.Producer.Retry.Max = 2
    	sconfig.Producer.Retry.Backoff = (10 * time.Second)
    	sconfig.Producer.Return.Successes = true
    	sconfig.Producer.Return.Errors = true
    	sconfig.Producer.RequiredAcks = 1
    	sconfig.Producer.Timeout = (10 * time.Second)
    	sconfig.Net.ReadTimeout = (10 * time.Second)
    	sconfig.Net.DialTimeout = (10 * time.Second)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/collect/QueuesTest.java

          assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, MILLISECONDS));
    
          Producer producer = new Producer(q, 1);
          // producing one, will ask for two
          Future<?> producerThread = threadPool.submit(producer);
          producer.beganProducing.await();
    
          // make sure we time out
          Stopwatch timer = Stopwatch.createStarted();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  9. internal/event/target/kafka.go

    	config.Producer.Retry.Max = 2
    	config.Producer.Retry.Backoff = (1 * time.Second)
    	config.Producer.Return.Successes = true
    	config.Producer.Return.Errors = true
    	config.Producer.RequiredAcks = 1
    	config.Producer.Timeout = (5 * time.Second)
    	// Set Producer Compression
    	cc, ok := codecs[strings.ToLower(args.Producer.Compression)]
    	if ok {
    		config.Producer.Compression = cc
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  10. docs/LICENSE

         Licensor. For purposes of this Public License, where the Licensed
         Material is a musical work, performance, or sound recording,
         Adapted Material is always produced where the Licensed Material is
         synched in timed relation with a moving image.
    
      b. Adapter's License means the license You apply to Your Copyright
         and Similar Rights in Your contributions to Adapted Material in
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon May 10 16:50:06 GMT 2021
    - 18.2K bytes
    - Click Count (0)
Back to Top