public class ArchivedExecutionVertex extends Object implements AccessExecutionVertex, Serializable
Constructor and Description |
---|
ArchivedExecutionVertex(ExecutionVertex vertex) |
ArchivedExecutionVertex(int subTaskIndex,
String taskNameWithSubtask,
ArchivedExecution currentExecution,
EvictingBoundedList<ArchivedExecution> priorExecutions) |
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
getCurrentAssignedResourceLocation()
Returns the
TaskManagerLocation for this execution vertex. |
ArchivedExecution |
getCurrentExecutionAttempt()
Returns the current execution for this execution vertex.
|
ExecutionState |
getExecutionState()
Returns the current
ExecutionState for this execution vertex. |
String |
getFailureCauseAsString()
Returns the exception that caused the job to fail.
|
int |
getParallelSubtaskIndex()
Returns the subtask index of this execution vertex.
|
ArchivedExecution |
getPriorExecutionAttempt(int attemptNumber)
Returns the execution for the given attempt number.
|
long |
getStateTimestamp(ExecutionState state)
Returns the timestamp for the given
ExecutionState . |
String |
getTaskNameWithSubtaskIndex()
Returns the name of this execution vertex in the format "myTask (2/7)".
|
public ArchivedExecutionVertex(ExecutionVertex vertex)
public ArchivedExecutionVertex(int subTaskIndex, String taskNameWithSubtask, ArchivedExecution currentExecution, EvictingBoundedList<ArchivedExecution> priorExecutions)
public String getTaskNameWithSubtaskIndex()
AccessExecutionVertex
getTaskNameWithSubtaskIndex
in interface AccessExecutionVertex
public int getParallelSubtaskIndex()
AccessExecutionVertex
getParallelSubtaskIndex
in interface AccessExecutionVertex
public ArchivedExecution getCurrentExecutionAttempt()
AccessExecutionVertex
getCurrentExecutionAttempt
in interface AccessExecutionVertex
public ExecutionState getExecutionState()
AccessExecutionVertex
ExecutionState
for this execution vertex.getExecutionState
in interface AccessExecutionVertex
public long getStateTimestamp(ExecutionState state)
AccessExecutionVertex
ExecutionState
.getStateTimestamp
in interface AccessExecutionVertex
state
- state for which the timestamp should be returnedpublic String getFailureCauseAsString()
AccessExecutionVertex
getFailureCauseAsString
in interface AccessExecutionVertex
"(null)"
public TaskManagerLocation getCurrentAssignedResourceLocation()
AccessExecutionVertex
TaskManagerLocation
for this execution vertex.getCurrentAssignedResourceLocation
in interface AccessExecutionVertex
@Nullable public ArchivedExecution getPriorExecutionAttempt(int attemptNumber)
AccessExecutionVertex
getPriorExecutionAttempt
in interface AccessExecutionVertex
attemptNumber
- attempt number of execution to be returnedCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.