- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 88 for aggregate (0.04 sec)
-
internal/s3select/sql/aggregation.go
return e.aggregate.runningSum, err case aggFnMin: if !e.aggregate.seen { // No rows were seen by MIN return FromNull(), nil } return e.aggregate.runningMin, nil case aggFnMax: if !e.aggregate.seen { // No rows were seen by MAX return FromNull(), nil } return e.aggregate.runningMax, nil case aggFnSum: // TODO: check if returning 0 when no rows were seenRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 7.9K bytes - Viewed (0) -
api/pom.xml
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Sun Jun 29 22:37:39 UTC 2025 - 3.2K bytes - Viewed (0) -
impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/StrategyOrchestratorTest.java
assertTrue(result.success(), "Orchestrator should succeed"); assertEquals(2, result.processedPoms().size(), "Should aggregate processed POMs"); assertEquals(2, result.modifiedPoms().size(), "Should aggregate modified POMs"); assertEquals(0, result.errorPoms().size(), "Should have no errors"); } @TestRegistered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Nov 18 18:03:26 UTC 2025 - 12.3K bytes - Viewed (0) -
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 Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Dec 09 15:58:48 UTC 2025 - 34.3K bytes - Viewed (0) -
internal/bucket/bandwidth/measurement.go
atomic.AddUint64(&m.bytesSinceLastWindow, bytes) } // updateExponentialMovingAverage processes the measurements captured so far. func (m *bucketMeasurement) 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sat Jun 03 20:41:51 UTC 2023 - 2.9K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/graph/FilteredProjectDependencyGraph.java
// Distinct the projects to avoid duplicates. Duplicates are possible in multi-module projects. // // Given a scenario where there is an aggregate POM with modules A, B, C, D, and E and project E depends on // A, B, C, and D. If the aggregate POM is being filtered for non-transitive and downstream dependencies whereRegistered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Jun 19 16:34:39 UTC 2025 - 6.4K 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 Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Dec 09 15:58:48 UTC 2025 - 33.9K bytes - Viewed (0) -
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 Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 3.9K 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 Dec 28 03:35:09 UTC 2025 - Last Modified: Thu May 02 15:10:38 UTC 2024 - 1.8K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 2.8K bytes - Viewed (0)