Package org.elasticsearch.xpack.esql.datasources

Class ExternalSourceOperatorFactory

java.lang.Object

org.elasticsearch.xpack.esql.datasources.ExternalSourceOperatorFactory

All Implemented Interfaces:

Describable, Operator.OperatorFactory, SourceOperator.SourceOperatorFactory

public class ExternalSourceOperatorFactory
extends Object
implements SourceOperator.SourceOperatorFactory

Factory for creating source operators that read from external storage using the StorageProvider and FormatReader abstractions. This is the generic implementation that works with any StorageProvider (HTTP, S3, local) and any FormatReader (CSV, Parquet, etc.). The factory creates operators that:

• Use StorageProvider to access the storage object
• Use FormatReader to parse the data format
• Produce ESQL Page batches for the query pipeline

Constructor Summary

Constructors

Constructor	Description
ExternalSourceOperatorFactory(StorageProvider storageProvider, FormatReader formatReader, StoragePath path, List<Attribute> attributes, int batchSize)
ExternalSourceOperatorFactory(StorageProvider storageProvider, FormatReader formatReader, StoragePath path, List<Attribute> attributes, int batchSize, int rowLimit, ExternalSliceQueue sliceQueue)

Method Summary

Modifier and Type	Method	Description
String	describe()
SourceOperator	get(DriverContext driverContext)

Methods inherited from class java.lang.Object

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

Constructor Details

ExternalSourceOperatorFactory

public ExternalSourceOperatorFactory(StorageProvider storageProvider,
 FormatReader formatReader,
 StoragePath path,
 List<Attribute> attributes,
 int batchSize,
 int rowLimit,
 @Nullable
 ExternalSliceQueue sliceQueue)

ExternalSourceOperatorFactory

public ExternalSourceOperatorFactory(StorageProvider storageProvider,
 FormatReader formatReader,
 StoragePath path,
 List<Attribute> attributes,
 int batchSize)

Method Details

get

public SourceOperator get(DriverContext driverContext)

Specified by:

get in interface Operator.OperatorFactory

Specified by:

get in interface SourceOperator.SourceOperatorFactory

describe

public String describe()

Specified by:

describe in interface Describable