Package org.elasticsearch.xpack.esql.datasources

Class AsyncConnectorSourceOperatorFactory

java.lang.Object

org.elasticsearch.xpack.esql.datasources.AsyncConnectorSourceOperatorFactory

All Implemented Interfaces:

Describable, Operator.OperatorFactory, SourceOperator.SourceOperatorFactory

public class AsyncConnectorSourceOperatorFactory
extends Object
implements SourceOperator.SourceOperatorFactory

Single-split source operator factory that executes a connector query on a background thread and feeds pages into an AsyncExternalSourceBuffer for the driver to consume.

Constructor Summary

Constructors

Constructor	Description
AsyncConnectorSourceOperatorFactory(Connector connector, QueryRequest baseRequest, int maxBufferSize, Executor executor)
AsyncConnectorSourceOperatorFactory(Connector connector, QueryRequest baseRequest, int maxBufferSize, Executor executor, 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

AsyncConnectorSourceOperatorFactory

public AsyncConnectorSourceOperatorFactory(Connector connector,
 QueryRequest baseRequest,
 int maxBufferSize,
 Executor executor,
 @Nullable
 ExternalSliceQueue sliceQueue)

AsyncConnectorSourceOperatorFactory

public AsyncConnectorSourceOperatorFactory(Connector connector,
 QueryRequest baseRequest,
 int maxBufferSize,
 Executor executor)

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