Class CsvDataSourcePlugin
java.lang.Object
org.elasticsearch.plugins.Plugin
org.elasticsearch.xpack.esql.datasource.csv.CsvDataSourcePlugin
- All Implemented Interfaces:
Closeable,AutoCloseable,DataSourcePlugin
Data source plugin that provides CSV and TSV format support for ESQL external data sources.
This plugin registers two format readers:
csv— comma-delimited (.csvfiles)tsv— tab-delimited (.tsvfiles)
Both readers use Jackson's CSV parser for robust parsing with proper quote and escape handling. They support:
- Schema discovery from file headers (column_name:type_name format)
- Column projection for efficient reads
- Batch reading with configurable batch sizes
- Direct conversion to ESQL Page format
The Jackson CSV dependency is isolated in this module to keep the core ESQL plugin free of third-party format libraries.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.plugins.Plugin
Plugin.PluginServices -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.elasticsearch.plugins.Plugin
additionalSettings, close, createComponents, getAdditionalIndexSettingProviders, getBootstrapChecks, getExecutorBuilders, getIndexTemplateMetadataUpgrader, getNamedWriteables, getNamedXContent, getProjectCustomMetadataUpgraders, getSettings, getSettingsFilter, onIndexModuleMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.xpack.esql.datasources.spi.DataSourcePlugin
connectors, decompressionCodecs, filterPushdownSupport, namedWriteables, operatorFactories, sourceFactories, storageProviders, storageProviders, supportedCatalogs, supportedConnectorSchemes, supportedSchemes, tableCatalogs
-
Constructor Details
-
CsvDataSourcePlugin
public CsvDataSourcePlugin()
-
-
Method Details
-
formatSpecs
- Specified by:
formatSpecsin interfaceDataSourcePlugin
-
formatReaders
- Specified by:
formatReadersin interfaceDataSourcePlugin
-