Package org.elasticsearch.xpack.esql.datasource.ndjson

Class NdJsonDataSourcePlugin

java.lang.Object

org.elasticsearch.plugins.Plugin

org.elasticsearch.xpack.esql.datasource.ndjson.NdJsonDataSourcePlugin

All Implemented Interfaces:

Closeable, AutoCloseable, DataSourcePlugin

public class NdJsonDataSourcePlugin
extends Plugin
implements DataSourcePlugin

Data source plugin that provides NDJSON format support for ESQL external data sources.

The NDJSON reader performs schema inference from the first 100 non-empty lines, resolves type conflicts to KEYWORD, marks nested objects/arrays as UNSUPPORTED, and ignores malformed lines while logging warnings with their line numbers.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.plugins.Plugin

Plugin.PluginServices

Constructor Summary

Constructors

Constructor	Description
NdJsonDataSourcePlugin()

Method Summary

Modifier and Type	Method	Description
Map<String,FormatReaderFactory>	formatReaders(Settings settings)
Set<FormatSpec>	formatSpecs()

Methods inherited from class org.elasticsearch.plugins.Plugin

additionalSettings, close, createComponents, getAdditionalIndexSettingProviders, getBootstrapChecks, getExecutorBuilders, getIndexTemplateMetadataUpgrader, getNamedWriteables, getNamedXContent, getProjectCustomMetadataUpgraders, getSettings, getSettingsFilter, onIndexModule

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.xpack.esql.datasources.spi.DataSourcePlugin

connectors, decompressionCodecs, filterPushdownSupport, namedWriteables, operatorFactories, sourceFactories, storageProviders, storageProviders, supportedCatalogs, supportedConnectorSchemes, supportedSchemes, tableCatalogs

Constructor Details

NdJsonDataSourcePlugin

public NdJsonDataSourcePlugin()

Method Details

formatSpecs

public Set<FormatSpec> formatSpecs()

Specified by:

formatSpecs in interface DataSourcePlugin

formatReaders

public Map<String,FormatReaderFactory> formatReaders(Settings settings)

Specified by:

formatReaders in interface DataSourcePlugin