org.apache.spark.status

Class LiveTask

Object

org.apache.spark.status.LiveTask

public class LiveTask
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Object

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

Constructor Detail

LiveTask

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

Method Detail

info

public TaskInfo info()

errorMessage

public scala.Option<String> errorMessage()

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)