- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for aggregate (0.04 sec)
-
api/pom.xml
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sun Jun 29 22:37:39 UTC 2025 - 3.2K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/BucketExtensions.kt
* if some elements are too small, they will be aggregated by smallElementAggregateFunction. * * @param list the list to split, must be ordered by size desc * @param toIntFunction the function used to map the element to its "size" * @param largeElementSplitFunction the function used to further split the large element into smaller pieces * @param smallElementAggregateFunction the function used to aggregate tiny elements into a large bucket
Registered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Wed Feb 12 09:12:03 UTC 2025 - 5.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TreeMultiset.java
+ aggregateAboveRange(aggr, node.left); } } @Override public int size() { return Ints.saturatedCast(aggregateForEntries(Aggregate.SIZE)); } @Override int distinctElements() { return Ints.saturatedCast(aggregateForEntries(Aggregate.DISTINCT)); } static int distinctElements(@Nullable AvlNode<?> node) { return (node == null) ? 0 : node.distinctElements; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.8K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/RepositoryFactory.java
@Nonnull RemoteRepository createRemote(@Nonnull String id, @Nonnull String url); @Nonnull RemoteRepository createRemote(@Nonnull Repository repository); @Nonnull List<RemoteRepository> aggregate( @Nonnull Session session, @Nonnull List<RemoteRepository> dominant, @Nonnull List<RemoteRepository> recessive, boolean processRecessive);
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Thu May 02 15:10:38 UTC 2024 - 1.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CollectionFuture.java
import com.google.errorprone.annotations.concurrent.LazyInit; import com.google.j2objc.annotations.RetainedLocalRef; import java.util.Collections; import java.util.List; import org.jspecify.annotations.Nullable; /** Aggregate future that collects (stores) results of each future. */ @GwtCompatible abstract class CollectionFuture<V extends @Nullable Object, C extends @Nullable Object> extends AggregateFuture<V, C> { /*
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 3.9K bytes - Viewed (0) -
cmd/tier-last-day-stats.go
cl.forwardTo(cm.UpdatedAt) merged.UpdatedAt = cm.UpdatedAt } for i := range cl.Bins { merged.Bins[i] = cl.Bins[i].add(cm.Bins[i]) } return merged } // DailyAllTierStats is used to aggregate last day tier stats across MinIO servers type DailyAllTierStats map[string]lastDayTierStats func (l DailyAllTierStats) merge(m DailyAllTierStats) { for tier, st := range m { l[tier] = l[tier].merge(st) } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 2.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import java.util.logging.Level; import org.jspecify.annotations.Nullable; /** * A helper which does some thread-safe operations for aggregate futures, which must be implemented * differently in GWT. Namely: * * <ul> * <li>Lazily initializes a set of seen exceptions * <li>Decrements a counter atomically * </ul> */ @GwtCompatible
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.5K bytes - Viewed (0) -
LICENSE
in or on a volume of a storage or distribution medium, is called an "aggregate" if the compilation and its resulting copyright are not used to limit the access or legal rights of the compilation's users beyond what the individual works permit. Inclusion of a covered work in an aggregate does not cause this License to apply to the other parts of the aggregate. 6. Conveying Non-Source Forms.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 33.7K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
atomic.AddUint64(&m.bytesSinceLastWindow, bytes) } // updateExponentialMovingAverage processes the measurements captured so far. func (m *rateMeasurement) updateExponentialMovingAverage(endTime time.Time) { // Calculate aggregate avg bandwidth and exp window avg m.lock.Lock() defer func() { m.startTime = endTime m.lock.Unlock() }() if m.startTime.IsZero() { return } if endTime.Before(m.startTime) { return
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 14.2K bytes - Viewed (0) -
docs/bigdata/README.md
``` sudo pip install yq alias kv-pairify='yq ".configuration[]" | jq ".[]" | jq -r ".name + \"=\" + .value"' ``` Let's take for example a set of 12 compute nodes with an aggregate memory of _1.2TiB_, we need to do following settings for optimal results. Add the following optimal entries for _core-site.xml_ to configure _s3a_ with **MinIO**. Most important options here are ```
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 14.7K bytes - Viewed (0)