Module org.elasticsearch.compute
Package org.elasticsearch.compute.aggregation
package org.elasticsearch.compute.aggregation
-
ClassDescriptionGrouping state base class for "all first/last by int key" aggregators.Base class for the grouping state of all "all first/last by key" aggregators.Grouping state base class for "all first/last by long key" aggregators.Base class for array states that track which group ids have been set.Base class that extends
AbstractArrayStateto add failure tracking.A non-grouped aggregation.Builds aggregation implementations, closing over any state required to do so."Modes" for running an aggregate function.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.Picks the exponential histogram with the minimum integer sort key.Picks the exponential histogram with the minimum long sort key.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.Picks the tdigest with the minimum integer sort key.Picks the tdigest with the minimum long sort key.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.Picks the exponential histogram with the maximum integer sort key.Picks the exponential histogram with the maximum long sort key.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.Picks the tdigest with the maximum integer sort key.Picks the tdigest with the maximum long sort key.An aggregator that retrieves the first value it encounters.An aggregator that retrieves the first value it encounters.An aggregator that retrieves the first value it encounters.Returns the first non-null exponential histogram value encountered.An aggregator that retrieves the first value it encounters.An aggregator that retrieves the first value it encounters.An aggregator that retrieves the first value it encounters.Returns the first non-null tdigest value encountered.Aggregator state for an array of BytesRefs.A rate grouping aggregation definition for double.A rate grouping aggregation definition for float.A rate grouping aggregation definition for int.A rate grouping aggregation definition for long.Grouping aggregator for histogram_merge_over_time with exponential histogram values.WrapsExponentialHistogramStates.GroupingStateto carry temporality accessor and warnings.Grouping aggregator for histogram_merge_over_time with TDigest values.WrapsTDigestStates.GroupingStateto carry temporality accessor and warnings.Specialized CountAggregatorFunction for dense_vectors.SpecializedCountApproximateAggregatorFunctionfor dense_vectors.SpecializedCountApproximateGroupingAggregatorFunctionfor dense_vectors.Specialized CountGroupingAggregatorFunction for dense_vectors.A grouping state consisting of a singleExponentialHistogramper group, without a sort key.A state holding a singleExponentialHistogramwithout a sort key.A grouping state consisting of a singlelongvalue with aExponentialHistogramper group.A state consisting of a singlelongvalue with aExponentialHistogram.AAggregatorFunctionthat wraps another, filtering which positions are supplied to the aggregator.AAggregatorFunctionSupplierthat wraps another, filtering which positions are supplied to the aggregator.AGroupingAggregatorFunctionthat wraps another, filtering which positions are supplied to the aggregator.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.Provides a context for evaluating a grouping aggregator.Applies some grouping function likeminoravgto many values, grouped into buckets.Consume group ids to cause theGroupingAggregatorFunctionto group values at a particular position into a particular group.View into the agg that's prepared to emit results.An idelta grouping aggregation definition for double.An idelta grouping aggregation definition for int.An idelta grouping aggregation definition for long.Intermediate aggregation state descriptor.Exception thrown when an invalid temporality value is encountered during resolution.Aggregator state for an array of IPs.An irate grouping aggregation definition for double.An irate grouping aggregation definition for int.An irate grouping aggregation definition for long.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.A time-series aggregation function that collects the Last occurrence value of a time series in a specified interval.An irate grouping aggregation definition for double.An irate grouping aggregation definition for int.An irate grouping aggregation definition for long.A standard deviation aggregation definition for double.A standard deviation aggregation definition for float.A standard deviation aggregation definition for int.A standard deviation aggregation definition for long.A grouping state holding a singleTDigestHolderper group, without a sort key.A state holding a singleTDigestHolderwithout a sort key.A grouping state consisting of a singlelongvalue with aTDigestHolderper group.A state consisting of a singlelongvalue with aTDigestHolder.The metric temporality, specifying how to correctly interpret counter values.Helper class for efficiently resolving metric temporality (CUMULATIVE or DELTA) from aBytesRefBlock.An internal aggregate function that always emits intermediate (or partial) output regardless of the aggregate mode.Helper for theValuesIntAggregator,ValuesFloatAggregatorandValuesBytesRefAggregatorcollecting values after the first in each group are collected in a hash, keyed by the pair of groupId and value.Helper for theValuesLongAggregatorandValuesDoubleAggregatorcollecting values after the first in each group are collected in a hash, keyed by the pair of groupId and value.Algorithm for calculating standard deviation, one value at a time.AAggregatorFunctionSupplierthat wraps another, and apply a window function on the final aggregation.AGroupingAggregatorFunctionthat wraps another, and apply a window function on the final aggregation.