Class MasterService.TaskOutputs
- java.lang.Object
-
- org.elasticsearch.cluster.service.MasterService.TaskOutputs
-
- Enclosing class:
- MasterService
protected class MasterService.TaskOutputs extends java.lang.Object
Output created by executing a set of tasks provided as TaskInputs
-
-
Field Summary
Fields Modifier and Type Field Description java.util.Map<java.lang.Object,ClusterStateTaskExecutor.TaskResult>
executionResults
ClusterState
newClusterState
java.util.List<org.elasticsearch.cluster.service.MasterService.Batcher.UpdateTask>
nonFailedTasks
ClusterState
previousClusterState
MasterService.TaskInputs
taskInputs
-
Method Summary
Modifier and Type Method Description void
clusterStatePublished(ClusterChangedEvent clusterChangedEvent)
boolean
clusterStateUnchanged()
ClusterStatePublisher.AckListener
createAckListener(ThreadPool threadPool, ClusterState newClusterState)
void
notifyFailedTasks()
void
notifySuccessfulTasksOnUnchangedClusterState()
void
processedDifferentClusterState(ClusterState previousClusterState, ClusterState newClusterState)
void
publishingFailed(FailedToCommitClusterStateException t)
-
-
-
Field Detail
-
taskInputs
public final MasterService.TaskInputs taskInputs
-
previousClusterState
public final ClusterState previousClusterState
-
newClusterState
public final ClusterState newClusterState
-
nonFailedTasks
public final java.util.List<org.elasticsearch.cluster.service.MasterService.Batcher.UpdateTask> nonFailedTasks
-
executionResults
public final java.util.Map<java.lang.Object,ClusterStateTaskExecutor.TaskResult> executionResults
-
-
Method Detail
-
publishingFailed
public void publishingFailed(FailedToCommitClusterStateException t)
-
processedDifferentClusterState
public void processedDifferentClusterState(ClusterState previousClusterState, ClusterState newClusterState)
-
clusterStatePublished
public void clusterStatePublished(ClusterChangedEvent clusterChangedEvent)
-
createAckListener
public ClusterStatePublisher.AckListener createAckListener(ThreadPool threadPool, ClusterState newClusterState)
-
clusterStateUnchanged
public boolean clusterStateUnchanged()
-
notifyFailedTasks
public void notifyFailedTasks()
-
notifySuccessfulTasksOnUnchangedClusterState
public void notifySuccessfulTasksOnUnchangedClusterState()
-
-