Class PlanConcurrencyCalculator

java.lang.Object
org.elasticsearch.xpack.esql.planner.PlanConcurrencyCalculator

public class PlanConcurrencyCalculator extends Object
Calculates the maximum number of nodes that should be queried concurrently for the given data node plan.

Used to avoid overloading the cluster with concurrent requests that may not be needed.

  • Field Details

  • Method Details

    • calculateNodesConcurrency

      @Nullable public Integer calculateNodesConcurrency(PhysicalPlan dataNodePlan, Configuration configuration)
      Returns:
      null if there should be no limit, otherwise, the maximum number of nodes that should be queried concurrently.