Class TimeSeriesAggregateExec
java.lang.Object
org.elasticsearch.xpack.esql.core.tree.Node<PhysicalPlan>
org.elasticsearch.xpack.esql.plan.QueryPlan<PhysicalPlan>
org.elasticsearch.xpack.esql.plan.physical.PhysicalPlan
org.elasticsearch.xpack.esql.plan.physical.UnaryExec
org.elasticsearch.xpack.esql.plan.physical.AggregateExec
org.elasticsearch.xpack.esql.plan.physical.TimeSeriesAggregateExec
- All Implemented Interfaces:
NamedWriteable,Writeable,EstimatesRowSize
An extension of
Aggregate to perform time-series aggregation per time-series, such as rate or _over_time.
The grouping must be `_tsid` and `tbucket` or just `_tsid`.-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.xpack.esql.plan.physical.EstimatesRowSize
EstimatesRowSize.StateNested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionTimeSeriesAggregateExec(Source source, PhysicalPlan child, List<? extends Expression> groupings, List<? extends NamedExpression> aggregates, AggregatorMode mode, List<Attribute> intermediateAttributes, Integer estimatedRowSize, Bucket timeBucket) -
Method Summary
Modifier and TypeMethodDescriptionprotected NodeInfo<AggregateExec> info()replaceChild(PhysicalPlan newChild) timeBucketRounding(FoldContext foldContext) withAggregates(List<? extends NamedExpression> newAggregates) protected AggregateExecwithEstimatedSize(int estimatedRowSize) withMode(AggregatorMode newMode) voidwriteTo(StreamOutput out) Methods inherited from class org.elasticsearch.xpack.esql.plan.physical.AggregateExec
aggregates, computeReferences, equals, estimatedRowSize, estimateRowSize, getMode, groupings, hashCode, intermediateAttributes, outputMethods inherited from class org.elasticsearch.xpack.esql.plan.physical.UnaryExec
child, inputSet, outputSet, replaceChildrenMethods inherited from class org.elasticsearch.xpack.esql.plan.QueryPlan
computeExpressions, expressions, forEachExpression, forEachExpression, forEachExpressionDown, forEachExpressionUp, references, transformExpressionsDown, transformExpressionsDown, transformExpressionsOnly, transformExpressionsOnly, transformExpressionsOnlyUp, transformExpressionsUp, transformExpressionsUpMethods inherited from class org.elasticsearch.xpack.esql.core.tree.Node
anyMatch, children, collect, collectFirstChildren, collectLeaves, doCollectFirst, forEachDown, forEachDown, forEachDownMayReturnEarly, forEachProperty, forEachPropertyDown, forEachPropertyOnly, forEachPropertyUp, forEachUp, forEachUp, nodeName, nodeProperties, nodeString, propertiesToString, replaceChildrenSameSize, source, sourceLocation, sourceText, toString, transformChildren, transformDown, transformDown, transformDown, transformNodeProps, transformPropertiesDown, transformPropertiesOnly, transformPropertiesUp, transformUp, transformUp, transformUp
-
Field Details
-
ENTRY
-
-
Constructor Details
-
TimeSeriesAggregateExec
public TimeSeriesAggregateExec(Source source, PhysicalPlan child, List<? extends Expression> groupings, List<? extends NamedExpression> aggregates, AggregatorMode mode, List<Attribute> intermediateAttributes, Integer estimatedRowSize, Bucket timeBucket)
-
-
Method Details
-
writeTo
- Specified by:
writeToin interfaceWriteable- Overrides:
writeToin classAggregateExec- Throws:
IOException
-
getWriteableName
- Specified by:
getWriteableNamein interfaceNamedWriteable- Overrides:
getWriteableNamein classAggregateExec
-
info
- Overrides:
infoin classAggregateExec
-
replaceChild
- Overrides:
replaceChildin classAggregateExec
-
withAggregates
- Overrides:
withAggregatesin classAggregateExec
-
withMode
- Overrides:
withModein classAggregateExec
-
withEstimatedSize
- Overrides:
withEstimatedSizein classAggregateExec
-
timeBucket
-
timeBucketRounding
-