Package org.elasticsearch.xpack.esql.plugin

Class WeightedRoundRobinStrategy

java.lang.Object

org.elasticsearch.xpack.esql.plugin.WeightedRoundRobinStrategy

All Implemented Interfaces:

ExternalDistributionStrategy

public final class WeightedRoundRobinStrategy
extends Object
implements ExternalDistributionStrategy

Distributes external splits across data nodes using a Longest Processing Time (LPT) algorithm that considers ExternalSplit.estimatedSizeInBytes() for load balancing. When all splits report size information, larger splits are assigned first to the node with the least accumulated load. Falls back to plain round-robin when size info is absent.

Constructor Summary

Constructors

Constructor	Description
WeightedRoundRobinStrategy()
WeightedRoundRobinStrategy(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

WeightedRoundRobinStrategy

public WeightedRoundRobinStrategy(NodeEligibilityStrategy eligibility)

WeightedRoundRobinStrategy

public WeightedRoundRobinStrategy()

Method Details

planDistribution

public ExternalDistributionPlan planDistribution(ExternalDistributionContext context)

Specified by:

planDistribution in interface ExternalDistributionStrategy