Package org.elasticsearch.xpack.esql.datasources

Class OperatorFactoryRegistry

java.lang.Object

org.elasticsearch.xpack.esql.datasources.OperatorFactoryRegistry

public class OperatorFactoryRegistry
extends Object

Registry for source operator factories.

This registry provides a single entry point for creating source operator factories. It supports two modes:

1. ExternalSourceFactory: Unified factories for connectors, table catalogs, and file-based sources. ConnectorFactory instances are dispatched via the connector protocol; file-based sources go through FileSourceFactory.operatorFactory(); other factories use their operatorFactory() capability.
2. Plugin factories: Backward-compat bridge for DataSourcePlugin.operatorFactories().

Constructor Summary

Constructors

Constructor	Description
OperatorFactoryRegistry(Map<String,ExternalSourceFactory> sourceFactories, Map<String,SourceOperatorFactoryProvider> pluginFactories, Executor executor)
OperatorFactoryRegistry(Map<String,ExternalSourceFactory> sourceFactories, Map<String,SourceOperatorFactoryProvider> pluginFactories, Executor executor, Executor fileReadExecutor)

Method Summary

Modifier and Type	Method	Description
Executor	executor()
SourceOperator.SourceOperatorFactory	factory(SourceOperatorContext context)
Executor	fileReadExecutor()	Thread pool for file (and similar) background reads.
boolean	hasPluginFactory(String sourceType)
Map<String,ExternalSourceFactory>	sourceFactories()

Methods inherited from class java.lang.Object

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

Constructor Details

OperatorFactoryRegistry

public OperatorFactoryRegistry(Map<String,ExternalSourceFactory> sourceFactories,
 Map<String,SourceOperatorFactoryProvider> pluginFactories,
 Executor executor)

OperatorFactoryRegistry

public OperatorFactoryRegistry(Map<String,ExternalSourceFactory> sourceFactories,
 Map<String,SourceOperatorFactoryProvider> pluginFactories,
 Executor executor,
 Executor fileReadExecutor)

Method Details

factory

public SourceOperator.SourceOperatorFactory factory(SourceOperatorContext context)

hasPluginFactory

public boolean hasPluginFactory(String sourceType)

sourceFactories

public Map<String,ExternalSourceFactory> sourceFactories()

executor

public Executor executor()

fileReadExecutor

public Executor fileReadExecutor()

Thread pool for file (and similar) background reads. Isolated from executor (typically esql_worker, which also runs compute drivers) so blocked producers in buffer backpressure cannot starve the drivers that free buffer space.