Module org.elasticsearch.compute

Package org.elasticsearch.compute.aggregation

Class DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator

java.lang.Object

org.elasticsearch.compute.aggregation.DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator

public class DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator
extends Object

Grouping aggregator for histogram_merge_over_time with exponential histogram values. Delegates to HistogramMergeExponentialHistogramAggregator for the actual merge, but reads temporality from an additional channel and defaults null to Temporality.DELTA. Cumulative temporality is unsupported and produces a warning; affected values are skipped.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState	Wraps ExponentialHistogramStates.GroupingState to carry temporality accessor and warnings.

Constructor Summary

Constructors

Constructor	Description
DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator()

Method Summary

Modifier and Type	Method	Description
static void	combine(DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState current, int groupId, ExponentialHistogram value, int position, BytesRefBlock temporality)
static void	combineIntermediate(DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState current, int groupId, ExponentialHistogram value, boolean seen)
static Block	evaluateFinal(DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState state, IntVector selected, GroupingAggregatorEvaluationContext ctx)
static DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState	initGrouping(BigArrays bigArrays, DriverContext driverContext, Warnings warnings)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator

public DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator()

Method Details

initGrouping

public static DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState initGrouping(BigArrays bigArrays,
 DriverContext driverContext,
 Warnings warnings)

combine

public static void combine(DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState current,
 int groupId,
 ExponentialHistogram value,
 int position,
 BytesRefBlock temporality)

combineIntermediate

public static void combineIntermediate(DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState current,
 int groupId,
 ExponentialHistogram value,
 boolean seen)

evaluateFinal

public static Block evaluateFinal(DeltaOnlyHistogramMergeOverTimeExponentialHistogramAggregator.TemporalityAwareExpHistGroupingState state,
 IntVector selected,
 GroupingAggregatorEvaluationContext ctx)