org.apache.spark.status.api.v1

Class TaskData

java.lang.Object

org.apache.spark.status.api.v1.TaskData

public class TaskData
extends java.lang.Object

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.Seq<AccumulableInfo>	accumulatorUpdates()
int	attempt()
scala.Option<java.lang.String>	errorMessage()
java.lang.String	executorId()
java.lang.String	host()
int	index()
java.util.Date	launchTime()
boolean	speculative()
long	taskId()
java.lang.String	taskLocality()
scala.Option<TaskMetrics>	taskMetrics()

Methods inherited from class java.lang.Object

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

Method Detail

taskId

public long taskId()

index

public int index()

attempt

public int attempt()

launchTime

public java.util.Date launchTime()

executorId

public java.lang.String executorId()

host

public java.lang.String host()

taskLocality

public java.lang.String taskLocality()

speculative

public boolean speculative()

accumulatorUpdates

public scala.collection.Seq<AccumulableInfo> accumulatorUpdates()

errorMessage

public scala.Option<java.lang.String> errorMessage()

taskMetrics

public scala.Option<TaskMetrics> taskMetrics()