public static class ExecutionGraphMessages.ExecutionStateChanged extends Object implements RequiresLeaderSessionID, scala.Product, scala.Serializable
ExecutionVertex
param: jobID to which the vertex belongs param: vertexID of the ExecutionJobVertex to which the ExecutionVertex belongs param: taskName param: totalNumberOfSubTasks denotes the number of parallel subtasks param: subtaskIndex denotes the index of the ExecutionVertex param: executionID param: newExecutionState param: timestamp of the execution state change param: optionalMessage
Constructor and Description |
---|
ExecutionStateChanged(JobID jobID,
JobVertexID vertexID,
String taskName,
int totalNumberOfSubTasks,
int subtaskIndex,
ExecutionAttemptID executionID,
ExecutionState newExecutionState,
long timestamp,
String optionalMessage) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
executionID() |
JobID |
jobID() |
ExecutionState |
newExecutionState() |
String |
optionalMessage() |
int |
subtaskIndex() |
String |
taskName() |
long |
timestamp() |
String |
toString() |
int |
totalNumberOfSubTasks() |
JobVertexID |
vertexID() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public ExecutionStateChanged(JobID jobID, JobVertexID vertexID, String taskName, int totalNumberOfSubTasks, int subtaskIndex, ExecutionAttemptID executionID, ExecutionState newExecutionState, long timestamp, String optionalMessage)
public JobID jobID()
public JobVertexID vertexID()
public String taskName()
public int totalNumberOfSubTasks()
public int subtaskIndex()
public ExecutionAttemptID executionID()
public ExecutionState newExecutionState()
public long timestamp()
public String optionalMessage()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.