Package org.apache.spark.status

Class LiveTask

Object

org.apache.spark.status.LiveTask

public class LiveTask
extends Object

Constructor Summary

Constructors

Constructor	Description
LiveTask(TaskInfo info, int stageId, int stageAttemptId, scala.Option<Object> lastUpdateTime)

Method Summary

Modifier and Type	Method	Description
scala.Option<String>	errorMessage()
TaskInfo	info()
long	lastWriteTime()
TaskMetrics	updateMetrics(org.apache.spark.executor.TaskMetrics metrics)	Update the metrics for the task and return the difference between the previous and new values.
void	write(org.apache.spark.status.ElementTrackingStore store, long now, boolean checkTriggers)

Methods inherited from class java.lang.Object

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

Constructor Details

LiveTask

public LiveTask(TaskInfo info,
 int stageId,
 int stageAttemptId,
 scala.Option<Object> lastUpdateTime)

Method Details

errorMessage

public scala.Option<String> errorMessage()

info

public TaskInfo info()

updateMetrics

public TaskMetrics updateMetrics(org.apache.spark.executor.TaskMetrics metrics)

Update the metrics for the task and return the difference between the previous and new values.

Parameters:

metrics - (undocumented)

Returns:

(undocumented)

lastWriteTime

public long lastWriteTime()

write

public void write(org.apache.spark.status.ElementTrackingStore store,
 long now,
 boolean checkTriggers)