Package org.elasticsearch.xpack.esql.datasources

Class DataSourceModule

java.lang.Object

org.elasticsearch.xpack.esql.datasources.DataSourceModule

All Implemented Interfaces:

Closeable, AutoCloseable

public final class DataSourceModule
extends Object
implements Closeable

Module that collects all data source implementations from plugins.

This module registers lazy delegating factories per-plugin so that heavy dependencies (AWS SDK, Parquet, Arrow) are only loaded when a query targets that backend. Capability declarations (DataSourceCapabilities) are used for cheap routing and early validation without triggering classloading.

Constructor Summary

Constructors

Constructor	Description
DataSourceModule(List<DataSourcePlugin> dataSourcePlugins, DataSourceCapabilities capabilities, Settings settings, BlockFactory blockFactory, ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
DataSourceCapabilities	capabilities()
void	close()
OperatorFactoryRegistry	createOperatorFactoryRegistry(Executor executor)
FilterPushdownRegistry	filterPushdownRegistry()
FormatReaderRegistry	formatReaderRegistry()
Map<String,ExternalSourceFactory>	sourceFactories()
StorageProviderRegistry	storageProviderRegistry()

Methods inherited from class java.lang.Object

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

Constructor Details

DataSourceModule

public DataSourceModule(List<DataSourcePlugin> dataSourcePlugins,
 DataSourceCapabilities capabilities,
 Settings settings,
 BlockFactory blockFactory,
 ExecutorService executor)

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

capabilities

public DataSourceCapabilities capabilities()

storageProviderRegistry

public StorageProviderRegistry storageProviderRegistry()

formatReaderRegistry

public FormatReaderRegistry formatReaderRegistry()

sourceFactories

public Map<String,ExternalSourceFactory> sourceFactories()

filterPushdownRegistry

public FilterPushdownRegistry filterPushdownRegistry()

createOperatorFactoryRegistry

public OperatorFactoryRegistry createOperatorFactoryRegistry(Executor executor)