- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 133 for _producer (0.29 seconds)
-
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 orderCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 10.9K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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 inCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon May 10 16:50:06 GMT 2021 - 18.2K bytes - Click Count (0)