Module org.elasticsearch.server

Package org.elasticsearch.health.node.selection

Class HealthNodeTaskExecutor

java.lang.Object

org.elasticsearch.persistent.PersistentTasksExecutor<HealthNodeTaskParams>

org.elasticsearch.health.node.selection.HealthNodeTaskExecutor

public final class HealthNodeTaskExecutor
extends PersistentTasksExecutor<HealthNodeTaskParams>

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.persistent.PersistentTasksExecutor

PersistentTasksExecutor.Scope

Field Summary

Fields

Modifier and Type	Field	Description
static final Setting<Boolean>	ENABLED_SETTING

Fields inherited from class org.elasticsearch.persistent.PersistentTasksExecutor

NO_NODE_FOUND

Constructor Summary

Constructors

Constructor	Description
HealthNodeTaskExecutor(ClusterService clusterService)

Method Summary

Modifier and Type	Method	Description
protected HealthNode	createTask(long id, String type, String action, TaskId parentTaskId, PersistentTasksCustomMetadata.PersistentTask<HealthNodeTaskParams> taskInProgress, Map<String,String> headers)	Creates a AllocatedPersistentTask for communicating with task manager
static List<NamedWriteableRegistry.Entry>	getNamedWriteables()
static List<NamedXContentRegistry.Entry>	getNamedXContentParsers()
protected void	nodeOperation(AllocatedPersistentTask task, HealthNodeTaskParams params, PersistentTaskState state)	This operation will be executed on the executor node.
PersistentTasksExecutor.Scope	scope()

Methods inherited from class org.elasticsearch.persistent.PersistentTasksExecutor

automaticReassignmentOnShutdown, doGetAssignment, getAssignment, getDescription, getExecutor, getTaskName, selectLeastLoadedNode, validate

Methods inherited from class java.lang.Object

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

Field Details

ENABLED_SETTING

public static final Setting<Boolean> ENABLED_SETTING

Constructor Details

HealthNodeTaskExecutor

public HealthNodeTaskExecutor(ClusterService clusterService)

Method Details

scope

public PersistentTasksExecutor.Scope scope()

Overrides:

scope in class PersistentTasksExecutor<HealthNodeTaskParams>

nodeOperation

protected void nodeOperation(AllocatedPersistentTask task,
 HealthNodeTaskParams params,
 PersistentTaskState state)

Description copied from class: PersistentTasksExecutor

This operation will be executed on the executor node.

NOTE: The nodeOperation has to throw an exception, trigger task.markAsCompleted() or task.completeAndNotifyIfNeeded() methods to indicate that the persistent task has finished.

Specified by:

nodeOperation in class PersistentTasksExecutor<HealthNodeTaskParams>

createTask

protected HealthNode createTask(long id,
 String type,
 String action,
 TaskId parentTaskId,
 PersistentTasksCustomMetadata.PersistentTask<HealthNodeTaskParams> taskInProgress,
 Map<String,String> headers)

Description copied from class: PersistentTasksExecutor

Creates a AllocatedPersistentTask for communicating with task manager

Overrides:

createTask in class PersistentTasksExecutor<HealthNodeTaskParams>

getNamedXContentParsers

public static List<NamedXContentRegistry.Entry> getNamedXContentParsers()

getNamedWriteables

public static List<NamedWriteableRegistry.Entry> getNamedWriteables()