Package org.elasticsearch.action.admin.cluster.desirednodes

Class DesiredNodesClusterStateTaskExecutor

java.lang.Object

org.elasticsearch.action.admin.cluster.desirednodes.DesiredNodesClusterStateTaskExecutor

All Implemented Interfaces:

ClusterStateTaskExecutor<ClusterStateUpdateTask>

public class DesiredNodesClusterStateTaskExecutor
extends Object
implements ClusterStateTaskExecutor<ClusterStateUpdateTask>

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.cluster.ClusterStateTaskExecutor

ClusterStateTaskExecutor.ClusterTasksResult<T extends ClusterStateTaskListener>, ClusterStateTaskExecutor.TaskResult

Constructor Summary

Constructors

Constructor	Description
DesiredNodesClusterStateTaskExecutor()

Method Summary

Modifier and Type	Method	Description
ClusterStateTaskExecutor.ClusterTasksResult<ClusterStateUpdateTask>	execute(ClusterState currentState, List<ClusterStateUpdateTask> tasks)	Update the cluster state based on the current state and the given tasks.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.cluster.ClusterStateTaskExecutor

clusterStatePublished, describeTasks, runOnlyOnMaster

Constructor Details

DesiredNodesClusterStateTaskExecutor

public DesiredNodesClusterStateTaskExecutor()

Method Details

execute

public ClusterStateTaskExecutor.ClusterTasksResult<ClusterStateUpdateTask> execute(ClusterState currentState,
 List<ClusterStateUpdateTask> tasks)
                                                                            throws Exception

Description copied from interface: ClusterStateTaskExecutor

Update the cluster state based on the current state and the given tasks. Return the *same instance* if no state should be changed.

Specified by:

execute in interface ClusterStateTaskExecutor<ClusterStateUpdateTask>

Throws:

Exception