- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 87 for aggregate (0.23 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 seen
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 7.9K bytes - Viewed (0) -
api/pom.xml
XML - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Thu Apr 11 14:06:34 GMT 2024 - 3.7K 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
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Jun 03 20:41:51 GMT 2023 - 2.9K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/bucket-extensions.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
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Thu Nov 17 05:17:44 GMT 2022 - 4K bytes - Viewed (0) -
build-logic/buildquality/src/main/kotlin/gradlebuild.incubation-report-aggregation.gradle.kts
plugins { id("base") } val reports by configurations.creating { isVisible = false isCanBeResolved = false isCanBeConsumed = false description = "Dependencies to aggregate reports from" } val allIncubationReports = tasks.register<IncubatingApiAggregateReportTask>("allIncubationReports") { group = "verification" reports.from(resolver("txt"))
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Sat Sep 30 16:17:28 GMT 2023 - 1.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(@CheckForNull AvlNode<?> node) { return (node == null) ? 0 : node.distinctElements; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 34.2K 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) } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 2.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CollectionFuture.java
import com.google.errorprone.annotations.concurrent.LazyInit; import java.util.Collections; import java.util.List; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** Aggregate future that collects (stores) results of each future. */ @GwtCompatible(emulated = true) @ElementTypesAreNonnullByDefault abstract class CollectionFuture<V extends @Nullable Object, C extends @Nullable Object>
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 3.8K bytes - Viewed (0) -
architecture/networking/pilot.md
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Feb 07 17:53:24 GMT 2024 - 19.1K bytes - Viewed (0) -
common-protos/k8s.io/api/rbac/v1/generated.proto
import "k8s.io/apimachinery/pkg/runtime/schema/generated.proto"; // Package-wide variables from generator "generated". option go_package = "k8s.io/api/rbac/v1"; // AggregationRule describes how to locate ClusterRoles to aggregate into the ClusterRole message AggregationRule { // ClusterRoleSelectors holds a list of selectors which will be used to find ClusterRoles and create the rules.
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 7.6K bytes - Viewed (0)