Package org.elasticsearch.xpack.esql.datasources

Class FileSplitProvider

java.lang.Object

org.elasticsearch.xpack.esql.datasources.FileSplitProvider

All Implemented Interfaces:

SplitProvider

public class FileSplitProvider
extends Object
implements SplitProvider

Default SplitProvider for file-based sources. Converts each file in the FileList into a FileSplit, applying L1 partition pruning when filter hints and partition metadata are available.

When filter hints contain resolved Expression objects, evaluates them against each file's partition values to prune files that cannot match the filter.

Field Summary

Fields inherited from interface org.elasticsearch.xpack.esql.datasources.spi.SplitProvider

SINGLE

Constructor Summary

Constructors

Constructor	Description
FileSplitProvider()
FileSplitProvider(long targetSplitSizeBytes)
FileSplitProvider(long targetSplitSizeBytes, DecompressionCodecRegistry codecRegistry, StorageProviderRegistry storageRegistry, Settings settings)
FileSplitProvider(long targetSplitSizeBytes, DecompressionCodecRegistry codecRegistry, StorageProviderRegistry storageRegistry, FormatReaderRegistry formatRegistry, Settings settings)

Method Summary

Modifier and Type	Method	Description
List<ExternalSplit>	discoverSplits(SplitDiscoveryContext context)

Methods inherited from class java.lang.Object

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

Constructor Details

FileSplitProvider

public FileSplitProvider()

FileSplitProvider

public FileSplitProvider(long targetSplitSizeBytes)

FileSplitProvider

public FileSplitProvider(long targetSplitSizeBytes,
 DecompressionCodecRegistry codecRegistry,
 StorageProviderRegistry storageRegistry,
 Settings settings)

FileSplitProvider

public FileSplitProvider(long targetSplitSizeBytes,
 DecompressionCodecRegistry codecRegistry,
 StorageProviderRegistry storageRegistry,
 FormatReaderRegistry formatRegistry,
 Settings settings)

Method Details

discoverSplits

public List<ExternalSplit> discoverSplits(SplitDiscoveryContext context)

Specified by:

discoverSplits in interface SplitProvider