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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	SplitDiscoveryPhase.Result	Post-prune "scanned" accounting collected while resolving splits, surfaced at the root of the query profile.

Method Summary

Modifier and Type	Method	Description
static PhysicalPlan	resolveExternalSplits(PhysicalPlan plan, Map<String,ExternalSourceFactory> sourceFactories)
static PhysicalPlan	resolveExternalSplits(PhysicalPlan plan, Map<String,ExternalSourceFactory> sourceFactories, int maxRecordBytes)
static SplitDiscoveryPhase.Result	resolveExternalSplitsWithStats(PhysicalPlan plan, Map<String,ExternalSourceFactory> sourceFactories, int maxRecordBytes)	Like resolveExternalSplits(org.elasticsearch.xpack.esql.plan.physical.PhysicalPlan, java.util.Map<java.lang.String, org.elasticsearch.xpack.esql.datasources.spi.ExternalSourceFactory>), but also returns the post-prune scanned counts aggregated across every ExternalSourceExec in the plan.
static SplitDiscoveryPhase.Result	resolveExternalSplitsWithStats(PhysicalPlan plan, Map<String,ExternalSourceFactory> sourceFactories, int maxRecordBytes, BooleanSupplier isCancelled)	Like resolveExternalSplitsWithStats(PhysicalPlan, Map, int), but threads a cancellation signal into each SplitDiscoveryContext so a long-running discovery aborts promptly on cancel.

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)

resolveExternalSplits

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

resolveExternalSplitsWithStats

public static SplitDiscoveryPhase.Result resolveExternalSplitsWithStats(PhysicalPlan plan,
 Map<String,ExternalSourceFactory> sourceFactories,
 int maxRecordBytes)

Like resolveExternalSplits(org.elasticsearch.xpack.esql.plan.physical.PhysicalPlan, java.util.Map<java.lang.String, org.elasticsearch.xpack.esql.datasources.spi.ExternalSourceFactory>), but also returns the post-prune scanned counts aggregated across every ExternalSourceExec in the plan.

resolveExternalSplitsWithStats

public static SplitDiscoveryPhase.Result resolveExternalSplitsWithStats(PhysicalPlan plan,
 Map<String,ExternalSourceFactory> sourceFactories,
 int maxRecordBytes,
 BooleanSupplier isCancelled)

Like resolveExternalSplitsWithStats(PhysicalPlan, Map, int), but threads a cancellation signal into each SplitDiscoveryContext so a long-running discovery aborts promptly on cancel.