public abstract class TaskContext
extends Object
implements java.io.Serializable
Constructor and Description |
---|
TaskContext() |
Modifier and Type | Method and Description |
---|---|
abstract void |
addOnCompleteCallback(scala.Function0<scala.Unit> f)
Deprecated.
|
abstract TaskContext |
addTaskCompletionListener(scala.Function1<TaskContext,scala.Unit> f)
Add a listener in the form of a Scala closure to be executed on task completion.
|
abstract TaskContext |
addTaskCompletionListener(TaskCompletionListener listener)
Add a (Java friendly) listener to be executed on task completion.
|
abstract long |
attemptId() |
static TaskContext |
get()
Return the currently active TaskContext.
|
abstract boolean |
isCompleted()
Whether the task has completed.
|
abstract boolean |
isInterrupted()
Whether the task has been killed.
|
abstract boolean |
isRunningLocally() |
abstract int |
partitionId() |
abstract boolean |
runningLocally()
Deprecated.
|
abstract int |
stageId() |
abstract org.apache.spark.executor.TaskMetrics |
taskMetrics()
::DeveloperApi::
|
public static TaskContext get()
public abstract boolean isCompleted()
public abstract boolean isInterrupted()
@Deprecated public abstract boolean runningLocally()
public abstract boolean isRunningLocally()
public abstract TaskContext addTaskCompletionListener(TaskCompletionListener listener)
public abstract TaskContext addTaskCompletionListener(scala.Function1<TaskContext,scala.Unit> f)
@Deprecated public abstract void addOnCompleteCallback(scala.Function0<scala.Unit> f)
f
- Callback function.public abstract int stageId()
public abstract int partitionId()
public abstract long attemptId()
public abstract org.apache.spark.executor.TaskMetrics taskMetrics()