Package org.elasticsearch.persistent

Class PersistentTasksNodeService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.persistent.PersistentTasksNodeService

All Implemented Interfaces:

ClusterStateListener

public class PersistentTasksNodeService
extends AbstractComponent
implements ClusterStateListener

This component is responsible for coordination of execution of persistent tasks on individual nodes. It runs on all non-transport client nodes in the cluster and monitors cluster state changes to detect started commands.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PersistentTasksNodeService.Status

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor	Description
PersistentTasksNodeService(Settings settings, PersistentTasksService persistentTasksService, PersistentTasksExecutorRegistry persistentTasksExecutorRegistry, TaskManager taskManager, NodePersistentTasksExecutor nodePersistentTasksExecutor)

Method Summary

Modifier and Type	Method	Description
void	clusterChanged(ClusterChangedEvent event)	Called when cluster state changes.

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistentTasksNodeService

public PersistentTasksNodeService(Settings settings,
                                  PersistentTasksService persistentTasksService,
                                  PersistentTasksExecutorRegistry persistentTasksExecutorRegistry,
                                  TaskManager taskManager,
                                  NodePersistentTasksExecutor nodePersistentTasksExecutor)

Method Detail

clusterChanged

public void clusterChanged(ClusterChangedEvent event)

Description copied from interface: ClusterStateListener

Called when cluster state changes.

Specified by:

clusterChanged in interface ClusterStateListener