Package org.elasticsearch.persistent

Class AllocatedPersistentTask

java.lang.Object

org.elasticsearch.tasks.Task

org.elasticsearch.tasks.CancellableTask

org.elasticsearch.persistent.AllocatedPersistentTask

public class AllocatedPersistentTask
extends CancellableTask

Represents a executor node operation that corresponds to a persistent task

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AllocatedPersistentTask.State

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

Task.Status

Field Summary

Fields inherited from class org.elasticsearch.tasks.Task

X_OPAQUE_ID

Constructor Summary

Constructors

Constructor	Description
AllocatedPersistentTask(long id, String type, String action, String description, TaskId parentTask, Map<String,String> headers)

Method Summary

Modifier and Type	Method	Description
long	getAllocationId()
Exception	getFailure()
String	getPersistentTaskId()
Task.Status	getStatus()	Build a status for this task or null if this task doesn't have status.
protected void	init(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId)
protected boolean	isCompleted()
void	markAsCompleted()
void	markAsFailed(Exception e)
void	updatePersistentTaskState(PersistentTaskState state, ActionListener<PersistentTasksCustomMetadata.PersistentTask<?>> listener)	Updates the persistent state for the corresponding persistent task.
void	waitForPersistentTask(Predicate<PersistentTasksCustomMetadata.PersistentTask<?>> predicate, org.elasticsearch.core.TimeValue timeout, PersistentTasksService.WaitForPersistentTaskListener<?> listener)	Waits for a given persistent task to comply with a given predicate, then call back the listener accordingly.

Methods inherited from class org.elasticsearch.tasks.CancellableTask

getReasonCancelled, isCancelled, onCancelled, shouldCancelChildrenOnCancellation

Methods inherited from class org.elasticsearch.tasks.Task

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

Methods inherited from class java.lang.Object

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

Constructor Details

AllocatedPersistentTask

public AllocatedPersistentTask(long id,
 String type,
 String action,
 String description,
 TaskId parentTask,
 Map<String,String> headers)

Method Details

getStatus

public Task.Status getStatus()

Description copied from class: Task

Build a status for this task or null if this task doesn't have status. Since most tasks don't have status this defaults to returning null. While this can never perform IO it might be a costly operation, requiring collating lists of results, etc. So only use it if you need the value.

Overrides:

getStatus in class Task

updatePersistentTaskState

public void updatePersistentTaskState(PersistentTaskState state,
 ActionListener<PersistentTasksCustomMetadata.PersistentTask<?>> listener)

Updates the persistent state for the corresponding persistent task.

This doesn't affect the status of this allocated task.

getPersistentTaskId

public String getPersistentTaskId()

init

protected void init(PersistentTasksService persistentTasksService,
 TaskManager taskManager,
 String persistentTaskId,
 long allocationId)

getFailure

public Exception getFailure()

getAllocationId

public long getAllocationId()

waitForPersistentTask

public void waitForPersistentTask(Predicate<PersistentTasksCustomMetadata.PersistentTask<?>> predicate,
 @Nullable
 org.elasticsearch.core.TimeValue timeout,
 PersistentTasksService.WaitForPersistentTaskListener<?> listener)

Waits for a given persistent task to comply with a given predicate, then call back the listener accordingly.

Parameters:

predicate - the persistent task predicate to evaluate

timeout - a timeout for waiting

listener - the callback listener

isCompleted

protected final boolean isCompleted()

markAsCompleted

public void markAsCompleted()

markAsFailed

public void markAsFailed(Exception e)