org.apache.spark

Class TaskContextImpl

Object

org.apache.spark.TaskContext

org.apache.spark.TaskContextImpl

All Implemented Interfaces:

java.io.Serializable, Logging

public class TaskContextImpl
extends TaskContext
implements Logging

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TaskContextImpl(int stageId, int partitionId, long attemptId, boolean runningLocally, org.apache.spark.executor.TaskMetrics taskMetrics)

Method Summary

Methods

Modifier and Type	Method and Description
void	addOnCompleteCallback(scala.Function0<scala.runtime.BoxedUnit> f)
TaskContextImpl	addTaskCompletionListener(scala.Function1<TaskContext,scala.runtime.BoxedUnit> f)
TaskContextImpl	addTaskCompletionListener(TaskCompletionListener listener) Add a (Java friendly) listener to be executed on task completion.
long	attemptId()
boolean	isCompleted() Whether the task has completed.
boolean	isInterrupted() Whether the task has been killed.
boolean	isRunningLocally()
void	markInterrupted() Marks the task for interruption, i.e.
void	markTaskCompleted() Marks the task as completed and triggers the listeners.
int	partitionId()
boolean	runningLocally()
int	stageId()
org.apache.spark.executor.TaskMetrics	taskMetrics() ::DeveloperApi::

Methods inherited from class org.apache.spark.TaskContext

addOnCompleteCallback, addTaskCompletionListener, get

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

TaskContextImpl

public TaskContextImpl(int stageId,
               int partitionId,
               long attemptId,
               boolean runningLocally,
               org.apache.spark.executor.TaskMetrics taskMetrics)

Method Detail

stageId

public int stageId()

Specified by:

stageId in class TaskContext

partitionId

public int partitionId()

Specified by:

partitionId in class TaskContext

attemptId

public long attemptId()

Specified by:

attemptId in class TaskContext

runningLocally

public boolean runningLocally()

Specified by:

runningLocally in class TaskContext

taskMetrics

public org.apache.spark.executor.TaskMetrics taskMetrics()

Description copied from class: TaskContext

::DeveloperApi::

Specified by:

taskMetrics in class TaskContext

addTaskCompletionListener

public TaskContextImpl addTaskCompletionListener(TaskCompletionListener listener)

Description copied from class: TaskContext

Add a (Java friendly) listener to be executed on task completion. This will be called in all situation - success, failure, or cancellation. An example use is for HadoopRDD to register a callback to close the input stream.

Specified by:

addTaskCompletionListener in class TaskContext

addTaskCompletionListener

public TaskContextImpl addTaskCompletionListener(scala.Function1<TaskContext,scala.runtime.BoxedUnit> f)

addOnCompleteCallback

public void addOnCompleteCallback(scala.Function0<scala.runtime.BoxedUnit> f)

markTaskCompleted

public void markTaskCompleted()

Marks the task as completed and triggers the listeners.

markInterrupted

public void markInterrupted()

Marks the task for interruption, i.e. cancellation.

isCompleted

public boolean isCompleted()

Description copied from class: TaskContext

Whether the task has completed.

Specified by:

isCompleted in class TaskContext

isRunningLocally

public boolean isRunningLocally()

Specified by:

isRunningLocally in class TaskContext

isInterrupted

public boolean isInterrupted()

Description copied from class: TaskContext

Whether the task has been killed.

Specified by:

isInterrupted in class TaskContext