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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	cancelOnParentLeaving()	Returns true if this task should be automatically cancelled if the coordinating node that requested this task left the cluster.
long	getAllocationId()
java.lang.Exception	getFailure()
java.lang.String	getPersistentTaskId()
AllocatedPersistentTask.State	getState()
Task.Status	getStatus()	Build a status for this task or null if this task doesn't have status.
void	markAsCompleted()
void	markAsFailed(java.lang.Exception e)
boolean	shouldCancelChildrenOnCancellation()	Returns true if this task can potentially have children that need to be cancelled when it parent is cancelled.
void	updatePersistentStatus(Task.Status status, ActionListener<PersistentTasksCustomMetaData.PersistentTask<?>> listener)	Updates the persistent state for the corresponding persistent task.
void	waitForPersistentTaskStatus(java.util.function.Predicate<PersistentTasksCustomMetaData.PersistentTask<?>> predicate, TimeValue timeout, PersistentTasksService.WaitForPersistentTaskStatusListener<?> listener)	Waits for this persistent task to have the desired state.

Methods inherited from class org.elasticsearch.tasks.CancellableTask

getReasonCancelled, isCancelled, onCancelled

Methods inherited from class java.lang.Object

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

Methods inherited from class org.elasticsearch.tasks.Task

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

Constructor Detail

AllocatedPersistentTask

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

Method Detail

shouldCancelChildrenOnCancellation

public boolean shouldCancelChildrenOnCancellation()

Description copied from class: CancellableTask

Returns true if this task can potentially have children that need to be cancelled when it parent is cancelled.

Specified by:

shouldCancelChildrenOnCancellation in class CancellableTask

cancelOnParentLeaving

public final boolean cancelOnParentLeaving()

Description copied from class: CancellableTask

Returns true if this task should be automatically cancelled if the coordinating node that requested this task left the cluster.

Overrides:

cancelOnParentLeaving in class CancellableTask

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

updatePersistentStatus

public void updatePersistentStatus(Task.Status status,
                                   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 java.lang.String getPersistentTaskId()

getFailure

public java.lang.Exception getFailure()

getState

public AllocatedPersistentTask.State getState()

getAllocationId

public long getAllocationId()

waitForPersistentTaskStatus

public void waitForPersistentTaskStatus(java.util.function.Predicate<PersistentTasksCustomMetaData.PersistentTask<?>> predicate,
                                        @Nullable
                                        TimeValue timeout,
                                        PersistentTasksService.WaitForPersistentTaskStatusListener<?> listener)

Waits for this persistent task to have the desired state.

markAsCompleted

public void markAsCompleted()

markAsFailed

public void markAsFailed(java.lang.Exception e)