Package org.elasticsearch.xpack.esql.datasources.spi

package org.elasticsearch.xpack.esql.datasources.spi

Related Packages

Package	Description
org.elasticsearch.xpack.esql.datasources
org.elasticsearch.xpack.esql.datasources.cache
org.elasticsearch.xpack.esql.datasources.glob
org.elasticsearch.xpack.esql.datasources.pushdown
org.elasticsearch.xpack.esql.datasources.utils

Class	Description
AggregatePushdownSupport	SPI for declaring that a format can compute aggregates from file-level statistics.
AggregatePushdownSupport.Pushability
AggregateSpec	Specification for a single aggregate to be computed from file-level statistics.
AggregateSpec.AggType
ColumnBlockConversions	Converts columnar primitive arrays to ESQL Blocks, avoiding the per-element overhead of Block.Builder when the source data is already in columnar form.
Connector	A live connection to an external data source.
ConnectorFactory	Factory for creating connectors to external data sources.
DataSourcePlugin	Extension point for data source implementations.
DecompressionCodec	SPI for decompression codecs.
ErrorPolicy	Configures how format readers handle malformed or unparseable rows.
ErrorPolicy.Mode	Determines what happens to a row (or field) that fails to parse.
ExternalSourceFactory	Common interface for complete external data source factories.
ExternalSplit	A serializable, parallelizable unit of work for an external data source.
FileList	Indexed view over a resolved set of files from an external data source.
FilterPushdownSupport	SPI interface for filter pushdown support in external data sources.
FilterPushdownSupport.Pushability	Indicates whether an expression can be pushed to the data source.
FilterPushdownSupport.PushdownResult	Result of attempting to push filters to a data source.
FormatReadContext	Immutable context for a single FormatReader.read(org.elasticsearch.xpack.esql.datasources.spi.StorageObject, org.elasticsearch.xpack.esql.datasources.spi.FormatReadContext) or FormatReader.readAsync(org.elasticsearch.xpack.esql.datasources.spi.StorageObject, org.elasticsearch.xpack.esql.datasources.spi.FormatReadContext, java.util.concurrent.Executor, org.elasticsearch.action.ActionListener<org.elasticsearch.compute.operator.CloseableIterator<org.elasticsearch.compute.data.Page>>) call.
FormatReadContext.Builder
FormatReader	Unified interface for reading data formats.
FormatReader.SchemaResolution	Strategy for resolving schemas across multiple files in a glob/multi-file query.
FormatReaderFactory	Factory for creating FormatReader instances.
FormatSpec	Describes a file format this plugin provides: a logical format name and the file extensions that select it.
FrameIndex	Index of independently decompressible frames within a compressed file.
FrameIndex.FrameEntry
IndexedDecompressionCodec	Extension of DecompressionCodec for codecs that support index-based random access to independently compressed frames.
QueryRequest	Describes a query to execute against a connector.
RangeAwareFormatReader	Extension of FormatReader for columnar formats (Parquet, ORC) that support row-group-level split parallelism.
RangeAwareFormatReader.SplitRange	A byte range within a file with optional per-range statistics (e.g.
ResultCursor	Streaming cursor over query results from a connector.
SegmentableFormatReader	Extension of FormatReader for line-oriented text formats (CSV, NDJSON) that support intra-file parallel parsing.
SimpleSourceMetadata	Simple immutable implementation of SourceMetadata.
SimpleSourceMetadata.Builder	Builder for SimpleSourceMetadata.
SourceMetadata	Unified metadata output type returned by all schema discovery mechanisms.
SourceOperatorContext	Context for creating source operator factories.
SourceOperatorContext.Builder
SourceOperatorFactoryProvider	Functional interface for creating source operator factories.
SourceStatistics	Statistics about a data source for query planning and optimization.
SourceStatistics.ColumnStatistics	Statistics for an individual column.
Split	Represents a unit of work for a connector to execute.
SplitDiscoveryContext	Context passed to SplitProvider.discoverSplits(org.elasticsearch.xpack.esql.datasources.spi.SplitDiscoveryContext) containing all information needed to enumerate and optionally prune splits for an external source.
SplitProvider	Discovers parallelizable splits for an external data source.
SplittableDecompressionCodec	Extension of DecompressionCodec for codecs that support splitting compressed files into independently decompressible ranges aligned to compressed block boundaries.
StorageObject	Unified interface for storage object access.
StoragePath	Represents a location in a storage system.
StorageProvider	Abstraction for accessing objects in external storage systems.
StorageProviderFactory	Factory for creating StorageProvider instances.
TableCatalog	Connects to table catalog systems like Iceberg, Delta Lake, or Hudi.
TableCatalog.DataFile
TableCatalogFactory	Factory for creating TableCatalog instances.