public static class ShardStateAction.ShardStartedClusterStateTaskExecutor extends java.lang.Object implements ClusterStateTaskExecutor<ShardStateAction.ShardEntry>, ClusterStateTaskListener
ClusterStateTaskExecutor.ClusterTasksResult<T>, ClusterStateTaskExecutor.TaskResult
Constructor and Description |
---|
ShardStartedClusterStateTaskExecutor(AllocationService allocationService,
org.apache.logging.log4j.Logger logger) |
Modifier and Type | Method and Description |
---|---|
ClusterStateTaskExecutor.ClusterTasksResult<ShardStateAction.ShardEntry> |
execute(ClusterState currentState,
java.util.List<ShardStateAction.ShardEntry> tasks)
Update the cluster state based on the current state and the given tasks.
|
void |
onFailure(java.lang.String source,
java.lang.Exception e)
A callback called when execute fails.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clusterStatePublished, describeTasks, runOnlyOnMaster
clusterStateProcessed, onNoLongerMaster
public ShardStartedClusterStateTaskExecutor(AllocationService allocationService, org.apache.logging.log4j.Logger logger)
public ClusterStateTaskExecutor.ClusterTasksResult<ShardStateAction.ShardEntry> execute(ClusterState currentState, java.util.List<ShardStateAction.ShardEntry> tasks) throws java.lang.Exception
ClusterStateTaskExecutor
execute
in interface ClusterStateTaskExecutor<ShardStateAction.ShardEntry>
java.lang.Exception
public void onFailure(java.lang.String source, java.lang.Exception e)
ClusterStateTaskListener
onFailure
in interface ClusterStateTaskListener