Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator

Class TimeSeriesAggregationOperator

java.lang.Object

org.elasticsearch.compute.operator.HashAggregationOperator

org.elasticsearch.compute.operator.TimeSeriesAggregationOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, org.elasticsearch.core.Releasable

public class TimeSeriesAggregationOperator
extends HashAggregationOperator

A specialized version of HashAggregationOperator that aggregates time-series aggregations from time-series sources.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	TimeSeriesAggregationOperator.Factory

Nested classes/interfaces inherited from class org.elasticsearch.compute.operator.HashAggregationOperator

HashAggregationOperator.Builder, HashAggregationOperator.Status

Nested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator

Operator.OperatorFactory

Field Summary

Fields inherited from class org.elasticsearch.compute.operator.HashAggregationOperator

aggregatorFactories, aggregatorMode, aggregators, blockHash, blockHashSupplier, DEFAULT_PARTIAL_EMIT_KEYS_THRESHOLD, DEFAULT_PARTIAL_EMIT_UNIQUENESS_THRESHOLD, driverContext, emitCount, emitNanos, output, partialEmitKeysThreshold, partialEmitUniquenessThreshold, rowsAddedInCurrentBatch

Fields inherited from interface org.elasticsearch.compute.operator.Operator

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
TimeSeriesAggregationOperator(Rounding.Prepared timeBucket, DateFieldMapper.Resolution timeResolution, AggregatorMode aggregatorMode, List<GroupingAggregator.Factory> aggregators, Supplier<BlockHash> blockHash, Rounding.Prepared outputTimeBucket, DriverContext driverContext)

Method Summary

Modifier and Type	Method	Description
void	close()	notifies the operator that it won't be used anymore (i.e.
protected IntVector	customizeSelected(GroupingAggregator aggregator, IntVector selected)	Customize the selected groupIds that are sent to the agg's GroupingAggregatorFunction.prepareEvaluateIntermediate(org.elasticsearch.compute.data.IntVector, org.elasticsearch.compute.aggregation.GroupingAggregatorEvaluationContext) and GroupingAggregatorFunction.prepareEvaluateFinal(org.elasticsearch.compute.data.IntVector, org.elasticsearch.compute.aggregation.GroupingAggregatorEvaluationContext).
protected void	emit()
protected GroupingAggregatorEvaluationContext	evaluationContext(BlockHash blockHash)
void	finish()	notifies the operator that it won't receive any more input pages
protected boolean	shouldEmitPartialResultsPeriodically()

Methods inherited from class org.elasticsearch.compute.operator.HashAggregationOperator

addInput, canProduceMoreDataWithoutExtraInput, checkState, getOutput, isFinished, needsInput, status, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.compute.operator.Operator

isBlocked

Constructor Details

TimeSeriesAggregationOperator

public TimeSeriesAggregationOperator(Rounding.Prepared timeBucket,
 DateFieldMapper.Resolution timeResolution,
 AggregatorMode aggregatorMode,
 List<GroupingAggregator.Factory> aggregators,
 Supplier<BlockHash> blockHash,
 Rounding.Prepared outputTimeBucket,
 DriverContext driverContext)

Method Details

finish

public void finish()

Description copied from interface: Operator

notifies the operator that it won't receive any more input pages

Specified by:

finish in interface Operator

Overrides:

finish in class HashAggregationOperator

emit

protected void emit()

Overrides:

emit in class HashAggregationOperator

shouldEmitPartialResultsPeriodically

protected boolean shouldEmitPartialResultsPeriodically()

Overrides:

shouldEmitPartialResultsPeriodically in class HashAggregationOperator

customizeSelected

protected IntVector customizeSelected(GroupingAggregator aggregator,
 IntVector selected)

Description copied from class: HashAggregationOperator

Customize the selected groupIds that are sent to the agg's GroupingAggregatorFunction.prepareEvaluateIntermediate(org.elasticsearch.compute.data.IntVector, org.elasticsearch.compute.aggregation.GroupingAggregatorEvaluationContext) and GroupingAggregatorFunction.prepareEvaluateFinal(org.elasticsearch.compute.data.IntVector, org.elasticsearch.compute.aggregation.GroupingAggregatorEvaluationContext). TSDB uses this to do less work later on.

Overrides:

customizeSelected in class HashAggregationOperator

evaluationContext

protected GroupingAggregatorEvaluationContext evaluationContext(BlockHash blockHash)

Overrides:

evaluationContext in class HashAggregationOperator

close

public void close()

Description copied from interface: Operator

notifies the operator that it won't be used anymore (i.e. none of the other methods called), and its resources can be cleaned up

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Operator

Specified by:

close in interface org.elasticsearch.core.Releasable

Overrides:

close in class HashAggregationOperator