Package org.elasticsearch.xpack.esql.optimizer.rules.logical.promql

Class TranslatePromqlToEsqlPlan

java.lang.Object

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

org.elasticsearch.xpack.esql.rule.ParameterizedRule<PromqlCommand,LogicalPlan,LogicalOptimizerContext>

org.elasticsearch.xpack.esql.optimizer.rules.logical.OptimizerRules.ParameterizedOptimizerRule<PromqlCommand,LogicalOptimizerContext>

org.elasticsearch.xpack.esql.optimizer.rules.logical.promql.TranslatePromqlToEsqlPlan

public final class TranslatePromqlToEsqlPlan
extends OptimizerRules.ParameterizedOptimizerRule<PromqlCommand,LogicalOptimizerContext>

Translates PromQL logical plan into ESQL plan.

This rule runs before TranslateTimeSeriesAggregate to convert PromQL-specific plan into standard ESQL nodes (TimeSeriesAggregate, Aggregate, Eval, etc.) that can then be further optimized.

Translation examples:

 PromQL: rate(http_requests[5m])
 Result: TimeSeriesAggregate[rate(value), groupBy=[step]]

 PromQL: sum by (cluster) (rate(http_requests[5m]))
 Result: TimeSeriesAggregate[sum(rate(value)), groupBy=[step, cluster]]

 PromQL: avg(sum by (cluster) (rate(http_requests[5m])))
 Result: Aggregate[avg(sum_result), groupBy=[step]]
           \_ TimeSeriesAggregate[sum(rate(value)), groupBy=[step, cluster]]

 PromQL: avg(ceil(sum by (cluster) (rate(http_requests[5m]))))
 Result: Aggregate[avg(ceil_result), groupBy=[step]]
           \_ Eval[ceil(sum_result)]
                 \_ TimeSeriesAggregate[sum(rate(value)), groupBy=[step, cluster]]

 PromQL: time() - avg(sum by (cluster) (rate(http_requests[5m])))
 Result: Eval[time() - avg_result]
           \_ Aggregate[avg(sum_result), groupBy=[step]]
                 \_ TimeSeriesAggregate[sum(rate(value)), groupBy=[step, cluster]]
 

Translation mechanism:

Recursive descent via translateNode(). Each node returns a TranslationResult:

• plan the LogicalPlan built so far
• expression reference to this node's output, composed into parent expressions

Example translations:

• Selector: plan unchanged, expression = LastOverTime(field) or field reference
• AcrossSeriesAggregate: plan = new Aggregate, expression = reference to aggregate output
• PromqlFunctionCall: plan = Eval if child aggregated, expression = function(child expr)
• VectorBinaryOperator: plan = merged from both sides, expression = left op right

Field Summary

Fields

Modifier and Type	Field	Description
static final Duration	DEFAULT_LOOKBACK

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

log

Constructor Summary

Constructors

Constructor	Description
TranslatePromqlToEsqlPlan()

Method Summary

Modifier and Type	Method	Description
protected LogicalPlan	rule(PromqlCommand promqlCommand, LogicalOptimizerContext context)
static Expression	translateLabelMatcher(Source source, Expression field, LabelMatcher matcher)	Translates a single PromQL label matcher into an ESQL filter expression.

Methods inherited from class org.elasticsearch.xpack.esql.optimizer.rules.logical.OptimizerRules.ParameterizedOptimizerRule

apply

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

apply

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

Field Details

DEFAULT_LOOKBACK

public static final Duration DEFAULT_LOOKBACK

Constructor Details

TranslatePromqlToEsqlPlan

public TranslatePromqlToEsqlPlan()

Method Details

rule

protected LogicalPlan rule(PromqlCommand promqlCommand,
 LogicalOptimizerContext context)

Specified by:

rule in class OptimizerRules.ParameterizedOptimizerRule<PromqlCommand,LogicalOptimizerContext>

translateLabelMatcher

public static Expression translateLabelMatcher(Source source,
 Expression field,
 LabelMatcher matcher)

Translates a single PromQL label matcher into an ESQL filter expression.

Parameters:

source - the source location

matcher - the label matcher to translate

Returns:

the ESQL Expression, or null if the matcher matches all or none