Package org.elasticsearch.xpack.esql.action

Class EsqlQueryTask

java.lang.Object

org.elasticsearch.tasks.Task

org.elasticsearch.tasks.CancellableTask

org.elasticsearch.xpack.core.async.StoredAsyncTask<EsqlQueryResponse>

org.elasticsearch.xpack.esql.action.EsqlQueryTask

All Implemented Interfaces:

Traceable, AsyncTask

public abstract class EsqlQueryTask
extends StoredAsyncTask<EsqlQueryResponse>

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.tasks.CancellableTask

CancellableTask.CancellationListener

Nested classes/interfaces inherited from class org.elasticsearch.tasks.Task

Task.Status

Field Summary

Fields inherited from class org.elasticsearch.xpack.core.async.StoredAsyncTask

completionListeners

Fields inherited from class org.elasticsearch.tasks.Task

APM_TRACE_CONTEXT, HEADERS_TO_COPY, PARENT_APM_TRACE_CONTEXT, PARENT_TRACE_PARENT_HEADER, PARENT_TRACE_STATE, startTime, TRACE_ID, TRACE_PARENT_HTTP_HEADER, TRACE_START_TIME, TRACE_STATE, X_ELASTIC_PRODUCT_ORIGIN_HTTP_HEADER, X_ELASTIC_PROJECT_ID_HTTP_HEADER, X_OPAQUE_ID_HTTP_HEADER

Fields inherited from interface org.elasticsearch.xpack.core.async.AsyncTask

ASYNC_TASK_KEEP_ALIVE_STATUS

Constructor Summary

Constructors

Constructor	Description
EsqlQueryTask(String sessionId, long id, String type, String action, String description, TaskId parentTaskId, Map<String,String> headers, Map<String,String> originHeaders, AsyncExecutionId asyncExecutionId, org.elasticsearch.core.TimeValue keepAlive)

Method Summary

Modifier and Type	Method	Description
EsqlExecutionInfo	executionInfo()
EsqlQueryResponse	getCurrentResult()
void	onFailure(Exception e)
void	onResponse(EsqlQueryResponse response)
void	rescheduleCancellationOnExpiry()
protected abstract Scheduler.ScheduledCancellable	scheduleCancellationOnExpiry(long expirationTimeMillis)	Schedules task cancellation at the given expiration time
String	sessionId()
void	setExecutionInfo(EsqlExecutionInfo executionInfo)
void	setExpirationTime(long expirationTime, org.elasticsearch.core.TimeValue keepAlive)

Methods inherited from class org.elasticsearch.xpack.core.async.StoredAsyncTask

addCompletionListener, cancelTask, getExecutionId, getExpirationTimeMillis, getKeepAlive, getOriginHeaders, removeCompletionListener

Methods inherited from class org.elasticsearch.tasks.CancellableTask

addListener, ensureNotCancelled, getReasonCancelled, isCancelled, notifyIfCancelled, onCancelled, shouldCancelChildrenOnCancellation, toString

Methods inherited from class org.elasticsearch.tasks.Task

getAction, getDescription, getHeader, getId, getParentTaskId, getProjectId, getSpanId, getStartTime, getStartTimeNanos, getStatus, getType, headers, result, result, taskInfo, taskInfo

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.xpack.core.async.AsyncTask

isCancelled

Constructor Details

EsqlQueryTask

public EsqlQueryTask(String sessionId,
 long id,
 String type,
 String action,
 String description,
 TaskId parentTaskId,
 Map<String,String> headers,
 Map<String,String> originHeaders,
 AsyncExecutionId asyncExecutionId,
 org.elasticsearch.core.TimeValue keepAlive)

Method Details

setExecutionInfo

public void setExecutionInfo(EsqlExecutionInfo executionInfo)

executionInfo

public EsqlExecutionInfo executionInfo()

sessionId

public String sessionId()

getCurrentResult

public EsqlQueryResponse getCurrentResult()

Specified by:

getCurrentResult in class StoredAsyncTask<EsqlQueryResponse>

onResponse

public void onResponse(EsqlQueryResponse response)

Overrides:

onResponse in class StoredAsyncTask<EsqlQueryResponse>

onFailure

public void onFailure(Exception e)

Overrides:

onFailure in class StoredAsyncTask<EsqlQueryResponse>

scheduleCancellationOnExpiry

protected abstract Scheduler.ScheduledCancellable scheduleCancellationOnExpiry(long expirationTimeMillis)

Schedules task cancellation at the given expiration time

rescheduleCancellationOnExpiry

public void rescheduleCancellationOnExpiry()

setExpirationTime

public void setExpirationTime(long expirationTime,
 org.elasticsearch.core.TimeValue keepAlive)

Specified by:

setExpirationTime in interface AsyncTask

Overrides:

setExpirationTime in class StoredAsyncTask<EsqlQueryResponse>