Class ParallelizeTimeSeriesSource
java.lang.Object
org.elasticsearch.xpack.esql.rule.Rule<TimeSeriesAggregateExec,PhysicalPlan>
org.elasticsearch.xpack.esql.rule.ParameterizedRule<TimeSeriesAggregateExec,PhysicalPlan,LocalPhysicalOptimizerContext>
org.elasticsearch.xpack.esql.optimizer.PhysicalOptimizerRules.ParameterizedOptimizerRule<TimeSeriesAggregateExec,LocalPhysicalOptimizerContext>
org.elasticsearch.xpack.esql.optimizer.rules.physical.local.ParallelizeTimeSeriesSource
public class ParallelizeTimeSeriesSource
extends PhysicalOptimizerRules.ParameterizedOptimizerRule<TimeSeriesAggregateExec,LocalPhysicalOptimizerContext>
An optimization rule vertically partitions the time-series into three parts: time-series source, field extraction,
and time-series aggregation so that they can run parallel to speed up time-series query.
For the field-extraction part, it will use a specialized version for time-series indices.
-
Field Summary
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionrule(TimeSeriesAggregateExec plan, LocalPhysicalOptimizerContext context) Methods inherited from class org.elasticsearch.xpack.esql.optimizer.PhysicalOptimizerRules.ParameterizedOptimizerRule
applyMethods inherited from class org.elasticsearch.xpack.esql.rule.ParameterizedRule
apply
-
Constructor Details
-
ParallelizeTimeSeriesSource
public ParallelizeTimeSeriesSource()
-
-
Method Details
-
rule
- Specified by:
rulein classPhysicalOptimizerRules.ParameterizedOptimizerRule<TimeSeriesAggregateExec,LocalPhysicalOptimizerContext>
-