Package org.apache.spark.status.api.v1

Class TaskData

Object

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

public class TaskData
extends Object

Method Summary

Modifier and Type	Method	Description
scala.collection.Seq<AccumulableInfo>	accumulatorUpdates()
int	attempt()
scala.Option<Object>	duration()
scala.Option<String>	errorMessage()
String	executorId()
scala.collection.immutable.Map<String,String>	executorLogs()
long	gettingResultTime()
String	host()
int	index()
Date	launchTime()
int	partitionId()
scala.Option<Date>	resultFetchStart()
long	schedulerDelay()
boolean	speculative()
String	status()
long	taskId()
String	taskLocality()
scala.Option<TaskMetrics>	taskMetrics()

Methods inherited from class java.lang.Object

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

Method Details

taskId

public long taskId()

index

public int index()

attempt

public int attempt()

partitionId

public int partitionId()

launchTime

public Date launchTime()

resultFetchStart

public scala.Option<Date> resultFetchStart()

duration

public scala.Option<Object> duration()

executorId

public String executorId()

host

public String host()

status

public String status()

taskLocality

public String taskLocality()

speculative

public boolean speculative()

accumulatorUpdates

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

errorMessage

public scala.Option<String> errorMessage()

taskMetrics

public scala.Option<TaskMetrics> taskMetrics()

executorLogs

public scala.collection.immutable.Map<String,String> executorLogs()

schedulerDelay

public long schedulerDelay()

gettingResultTime

public long gettingResultTime()