Module org.elasticsearch.compute
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
A specialized version of
HashAggregationOperator that aggregates time-series aggregations from time-series sources.-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from class org.elasticsearch.compute.operator.HashAggregationOperator
HashAggregationOperator.HashAggregationOperatorFactory, HashAggregationOperator.StatusNested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator
Operator.OperatorFactory -
Field Summary
Fields inherited from class org.elasticsearch.compute.operator.HashAggregationOperator
aggregators, driverContext, emitNanosFields inherited from interface org.elasticsearch.compute.operator.Operator
MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE -
Constructor Summary
ConstructorsConstructorDescriptionTimeSeriesAggregationOperator(Rounding.Prepared timeBucket, List<GroupingAggregator.Factory> aggregators, Supplier<BlockHash> blockHash, DriverContext driverContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected GroupingAggregatorEvaluationContextevaluationContext(Block[] keys) Methods inherited from class org.elasticsearch.compute.operator.HashAggregationOperator
addInput, checkState, close, finish, getOutput, isFinished, needsInput, status, toString, wrapPage
-
Constructor Details
-
TimeSeriesAggregationOperator
public TimeSeriesAggregationOperator(Rounding.Prepared timeBucket, List<GroupingAggregator.Factory> aggregators, Supplier<BlockHash> blockHash, DriverContext driverContext)
-
-
Method Details
-
evaluationContext
- Overrides:
evaluationContextin classHashAggregationOperator
-