Package org.elasticsearch.xpack.esql.datasources

Class SplitDiscoveryPhase

java.lang.Object

org.elasticsearch.xpack.esql.datasources.SplitDiscoveryPhase

public final class SplitDiscoveryPhase
extends Object

Walks the physical plan tree, discovers splits for each ExternalSourceExec, and replaces them with split-enriched copies via ExternalSourceExec.withSplits(java.util.List<org.elasticsearch.xpack.esql.datasources.spi.ExternalSplit>).

Filter expressions from FilterExec ancestors are collected per-source so that each ExternalSourceExec only receives filters from its own ancestor chain, not from unrelated branches of the plan tree.

Method Summary

Modifier and Type	Method	Description
static PhysicalPlan	resolveExternalSplits(PhysicalPlan plan, Map<String,ExternalSourceFactory> sourceFactories)

Methods inherited from class java.lang.Object

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

Method Details

resolveExternalSplits

public static PhysicalPlan resolveExternalSplits(PhysicalPlan plan,
 Map<String,ExternalSourceFactory> sourceFactories)