Package org.elasticsearch.xpack.esql.plugin

Class AdaptiveStrategy

java.lang.Object

org.elasticsearch.xpack.esql.plugin.AdaptiveStrategy

All Implemented Interfaces:

ExternalDistributionStrategy

public final class AdaptiveStrategy
extends Object
implements ExternalDistributionStrategy

Adaptive distribution strategy for external sources.

Distributes when the plan contains pipeline breakers (aggregations, TopN) and there are multiple splits, or when the split count exceeds the number of eligible nodes. Stays on the coordinator for single splits or LIMIT-only plans.

Constructor Summary

Constructors

Constructor	Description
AdaptiveStrategy()
AdaptiveStrategy(NodeEligibilityStrategy eligibility)

Method Summary

Modifier and Type	Method	Description
ExternalDistributionPlan	planDistribution(ExternalDistributionContext context)

Methods inherited from class java.lang.Object

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

Constructor Details

AdaptiveStrategy

public AdaptiveStrategy(NodeEligibilityStrategy eligibility)

AdaptiveStrategy

public AdaptiveStrategy()

Method Details

planDistribution

public ExternalDistributionPlan planDistribution(ExternalDistributionContext context)

Specified by:

planDistribution in interface ExternalDistributionStrategy