ClusterStateTaskExecutor<ShardStateAction.StartedShardEntry>
, ClusterStateTaskListener
public static class ShardStateAction.ShardStartedClusterStateTaskExecutor extends java.lang.Object implements ClusterStateTaskExecutor<ShardStateAction.StartedShardEntry>, ClusterStateTaskListener
ClusterStateTaskExecutor.ClusterTasksResult<T>, ClusterStateTaskExecutor.TaskResult
Constructor | Description |
---|---|
ShardStartedClusterStateTaskExecutor(AllocationService allocationService,
org.apache.logging.log4j.Logger logger) |
Modifier and Type | Method | Description |
---|---|---|
ClusterStateTaskExecutor.ClusterTasksResult<ShardStateAction.StartedShardEntry> |
execute(ClusterState currentState,
java.util.List<ShardStateAction.StartedShardEntry> 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.
|
clusterStatePublished, describeTasks, runOnlyOnMaster
clusterStateProcessed, onNoLongerMaster
public ShardStartedClusterStateTaskExecutor(AllocationService allocationService, org.apache.logging.log4j.Logger logger)
public ClusterStateTaskExecutor.ClusterTasksResult<ShardStateAction.StartedShardEntry> execute(ClusterState currentState, java.util.List<ShardStateAction.StartedShardEntry> tasks) throws java.lang.Exception
ClusterStateTaskExecutor
execute
in interface ClusterStateTaskExecutor<ShardStateAction.StartedShardEntry>
java.lang.Exception
public void onFailure(java.lang.String source, java.lang.Exception e)
ClusterStateTaskListener
onFailure
in interface ClusterStateTaskListener