- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for reducer (0.18 sec)
-
android/guava/src/com/google/common/collect/Streams.java
R apply(double from, long index); } /** * Returns the last element of the specified stream, or {@link java.util.Optional#empty} if the * stream is empty. * * <p>Equivalent to {@code stream.reduce((a, b) -> b)}, but may perform significantly better. This * method's runtime will be between O(log n) and O(n), performing better on <a
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 37.4K bytes - Viewed (0) -
cmd/erasure-object.go
// which decides which condition it is useful to check if an object is dangling // // errs: errors from reading xl.meta in all disks // err: reduced errs // bucket: the object name in question func shouldCheckForDangling(err error, errs []error, bucket string) bool { // Avoid data in .minio.sys for now if bucket == minioMetaBucket { return false }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/Streams.java
R apply(double from, long index); } /** * Returns the last element of the specified stream, or {@link java.util.Optional#empty} if the * stream is empty. * * <p>Equivalent to {@code stream.reduce((a, b) -> b)}, but may perform significantly better. This * method's runtime will be between O(log n) and O(n), performing better on <a
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 36.8K bytes - Viewed (0) -
cmd/iam.go
updatedAt, addedOrRemoved, effectivePolicies, err = sys.store.PolicyDBUpdate(ctx, userOrGroup, isGroup, regUser, r.Policies, isAttach) if err != nil { return } // Notify all other MinIO peers to reload policy if !sys.HasWatcher() { for _, nerr := range globalNotificationSys.LoadPolicyMapping(ctx, userOrGroup, regUser, isGroup) { if nerr.Err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 29 16:01:48 UTC 2024 - 74.6K bytes - Viewed (0) -
cmd/erasure-healing-common.go
onlineDisks = make([]StorageAPI, len(disks)) // List all the file commit ids from parts metadata. modTimes := listObjectModtimes(partsMetadata, errs) // Reduce list of UUIDs to a single common value. modTime = commonTime(modTimes, quorum) if modTime.IsZero() || modTime.Equal(timeSentinel) { etags := listObjectETags(partsMetadata, errs, quorum)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 12.7K bytes - Viewed (0) -
guava/src/com/google/common/base/Stopwatch.java
* </ul> * * <p>The one downside of {@code Stopwatch} relative to {@link System#nanoTime()} is that {@code * Stopwatch} requires object allocation and additional method calls, which can reduce the accuracy * of the elapsed times reported. {@code Stopwatch} is still suitable for logging and metrics where * reasonably accurate values are sufficient. If the uncommon case that you need to maximize
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 9.3K bytes - Viewed (0) -
docs/fr/docs/tutorial/path-params-numeric-validations.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Oct 28 10:32:37 UTC 2024 - 6.9K bytes - Viewed (0) -
docs/pt/docs/advanced/custom-response.md
/// info | Informação Essa resposta requer a instalação do pacote `orjson`, com o comando `pip install orjson`, por exemplo. /// ### `UJSONResponse` Uma alternativa de resposta JSON utilizando a biblioteca <a href="https://github.com/ultrajson/ultrajson" class="external-link" target="_blank">`ujson`</a>. /// info | Informação
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Oct 29 11:47:10 UTC 2024 - 13.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableBiMapTest.java
/** * Tests for {@link ImmutableBiMap}. * * @author Jared Levy */ @GwtCompatible(emulated = true) @ElementTypesAreNonnullByDefault public class ImmutableBiMapTest extends TestCase { // TODO: Reduce duplication of ImmutableMapTest code @J2ktIncompatible @GwtIncompatible // suite public static Test suite() { TestSuite suite = new TestSuite(); suite.addTest(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 22.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Ordering.java
* * <p><b>Java 8+ users:</b> Use a chain of calls to {@link Comparator#thenComparing(Comparator)}, * or {@code comparatorCollection.stream().reduce(Comparator::thenComparing).get()} (if the * collection might be empty, also provide a default comparator as the {@code identity} parameter * to {@code reduce}). * * @param comparators the comparators to try in order */ @GwtCompatible(serializable = true)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 39.4K bytes - Viewed (0)