Package org.elasticsearch.xpack.esql.datasource.grpc

Class GrpcDataSourcePlugin

java.lang.Object

org.elasticsearch.plugins.Plugin

org.elasticsearch.xpack.esql.datasource.grpc.GrpcDataSourcePlugin

All Implemented Interfaces:

Closeable, AutoCloseable, DataSourcePlugin

public class GrpcDataSourcePlugin
extends Plugin
implements DataSourcePlugin

Registers the Arrow Flight connector for ESQL. Handles flight:// and grpc:// URIs for columnar data streaming via gRPC.

Nested Class Summary

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

Plugin.PluginServices

Constructor Summary

Constructors

Constructor	Description
GrpcDataSourcePlugin()

Method Summary

Modifier and Type	Method	Description
Map<String,ConnectorFactory>	connectors(Settings settings)
List<NamedWriteableRegistry.Entry>	getNamedWriteables()
Set<String>	supportedConnectorSchemes()

Methods inherited from class org.elasticsearch.plugins.Plugin

additionalSettings, close, createComponents, getAdditionalIndexSettingProviders, getBootstrapChecks, getExecutorBuilders, getIndexTemplateMetadataUpgrader, 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

decompressionCodecs, filterPushdownSupport, formatReaders, formatSpecs, namedWriteables, operatorFactories, sourceFactories, storageProviders, storageProviders, supportedCatalogs, supportedSchemes, tableCatalogs

Constructor Details

GrpcDataSourcePlugin

public GrpcDataSourcePlugin()

Method Details

supportedConnectorSchemes

public Set<String> supportedConnectorSchemes()

Specified by:

supportedConnectorSchemes in interface DataSourcePlugin

connectors

public Map<String,ConnectorFactory> connectors(Settings settings)

Specified by:

connectors in interface DataSourcePlugin

getNamedWriteables

public List<NamedWriteableRegistry.Entry> getNamedWriteables()

Overrides:

getNamedWriteables in class Plugin