Module org.elasticsearch.compute

Package org.elasticsearch.compute.aggregation

Class DeltaOnlyHistogramMergeOverTimeTDigestAggregator

java.lang.Object

org.elasticsearch.compute.aggregation.DeltaOnlyHistogramMergeOverTimeTDigestAggregator

public class DeltaOnlyHistogramMergeOverTimeTDigestAggregator
extends Object

Grouping aggregator for histogram_merge_over_time with TDigest values. Delegates to HistogramMergeTDigestAggregator 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	DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState	Wraps TDigestStates.GroupingState to carry temporality accessor and warnings.

Constructor Summary

Constructors

Constructor	Description
DeltaOnlyHistogramMergeOverTimeTDigestAggregator()

Method Summary

Modifier and Type	Method	Description
static void	combine(DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState current, int groupId, TDigestHolder value, int position, BytesRefBlock temporality)
static void	combineIntermediate(DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState current, int groupId, TDigestHolder value, boolean seen)
static Block	evaluateFinal(DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState state, IntVector selected, GroupingAggregatorEvaluationContext ctx)
static DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState	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

DeltaOnlyHistogramMergeOverTimeTDigestAggregator

public DeltaOnlyHistogramMergeOverTimeTDigestAggregator()

Method Details

initGrouping

public static DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState initGrouping(BigArrays bigArrays,
 DriverContext driverContext,
 Warnings warnings)

combine

public static void combine(DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState current,
 int groupId,
 TDigestHolder value,
 int position,
 BytesRefBlock temporality)

combineIntermediate

public static void combineIntermediate(DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState current,
 int groupId,
 TDigestHolder value,
 boolean seen)

evaluateFinal

public static Block evaluateFinal(DeltaOnlyHistogramMergeOverTimeTDigestAggregator.TemporalityAwareTDigestGroupingState state,
 IntVector selected,
 GroupingAggregatorEvaluationContext ctx)