Package org.elasticsearch.xpack.esql.analysis

Class InsertDefaultInnerTimeSeriesAggregate

java.lang.Object

org.elasticsearch.xpack.esql.rule.Rule<LogicalPlan,LogicalPlan>

org.elasticsearch.xpack.esql.analysis.InsertDefaultInnerTimeSeriesAggregate

public class InsertDefaultInnerTimeSeriesAggregate
extends Rule<LogicalPlan,LogicalPlan>

Ensures that TypedAttributes used inside a TimeSeriesAggregate are wrapped in a TimeSeriesAggregateFunction. Examples:

 foo + bar ->
 LAST_OVER_TIME(foo) + LAST_OVER_TIME(bar)

 SUM(foo + LAST_OVER_TIME(bar)) ->
 SUM(LAST_OVER_TIME(foo) + LAST_OVER_TIME(bar))

 foo / 2 + bar * 2 ->
 LAST_OVER_TIME(foo) / 2 + LAST_OVER_TIME(bar) * 2

 LAST(field, @timestamp) ->
 LAST(LAST_OVER_TIME(field), MAX_OVER_TIME(@timestamp))

 FIRST(field, @timestamp) ->
 FIRST(FIRST_OVER_TIME(field), MIN_OVER_TIME(@timestamp))
 

Field Summary

Fields inherited from class org.elasticsearch.xpack.esql.rule.Rule

log

Constructor Summary

Constructors

Constructor	Description
InsertDefaultInnerTimeSeriesAggregate()

Method Summary

Modifier and Type	Method	Description
LogicalPlan	apply(LogicalPlan logicalPlan)
LogicalPlan	rule(TimeSeriesAggregate aggregate)

Methods inherited from class org.elasticsearch.xpack.esql.rule.Rule

name, toString, typeToken

Methods inherited from class java.lang.Object

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

Constructor Details

InsertDefaultInnerTimeSeriesAggregate

public InsertDefaultInnerTimeSeriesAggregate()

Method Details

apply

public LogicalPlan apply(LogicalPlan logicalPlan)

Specified by:

apply in class Rule<LogicalPlan,LogicalPlan>

rule

public LogicalPlan rule(TimeSeriesAggregate aggregate)