Module org.elasticsearch.server

Package org.elasticsearch.persistent

Class PersistentTasksExecutorRegistry

java.lang.Object

org.elasticsearch.persistent.PersistentTasksExecutorRegistry

public class PersistentTasksExecutorRegistry
extends Object

Components that registers all persistent task executors

Constructor Summary

Constructors

Constructor	Description
PersistentTasksExecutorRegistry(Collection<PersistentTasksExecutor<?>> taskExecutors)

Method Summary

Modifier and Type	Method	Description
<Params extends PersistentTaskParams> PersistentTasksExecutor<Params>	getPersistentTaskExecutorSafe(String taskName)
static boolean	isClusterScopedTask(String taskName)	Returns true if the given task name corresponds to an executor with a PersistentTasksExecutor.scope() of PersistentTasksExecutor.Scope.CLUSTER.
static boolean	taskHasReassignmentOnShutdownDisabled(String taskName)	Returns true if the given task executor has the PersistentTasksExecutor.automaticReassignmentOnShutdown() flag set to false.

Methods inherited from class java.lang.Object

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

Constructor Details

PersistentTasksExecutorRegistry

public PersistentTasksExecutorRegistry(Collection<PersistentTasksExecutor<?>> taskExecutors)

Method Details

getPersistentTaskExecutorSafe

public <Params extends PersistentTaskParams>
PersistentTasksExecutor<Params> getPersistentTaskExecutorSafe(String taskName)

isClusterScopedTask

public static boolean isClusterScopedTask(String taskName)

Returns true if the given task name corresponds to an executor with a PersistentTasksExecutor.scope() of PersistentTasksExecutor.Scope.CLUSTER.

Parameters:

taskName - the name of the persistent task to check

taskHasReassignmentOnShutdownDisabled

public static boolean taskHasReassignmentOnShutdownDisabled(String taskName)

Returns true if the given task executor has the PersistentTasksExecutor.automaticReassignmentOnShutdown() flag set to false. Using a precomputed set avoids repeated registry lookups during reassignment checks.

Parameters:

taskName - the name of the persistent task to check