org.apache.spark.status

Class LiveJob

Object

org.apache.spark.status.LiveJob

public class LiveJob
extends Object

Constructor Summary

Constructors

Constructor and Description
LiveJob(int jobId, String name, scala.Option<java.util.Date> submissionTime, scala.collection.Seq<Object> stageIds, scala.Option<String> jobGroup, int numTasks)

Method Summary

Modifier and Type	Method and Description
int	activeStages()
int	activeTasks()
org.apache.spark.util.collection.OpenHashSet<Object>	completedIndices()
scala.collection.immutable.Set<Object>	completedStages()
int	completedTasks()
scala.Option<java.util.Date>	completionTime()
int	failedStages()
int	failedTasks()
int	jobId()
scala.collection.immutable.Map<String,Object>	killedSummary()
int	killedTasks()
long	lastWriteTime()
scala.collection.immutable.Set<Object>	skippedStages()
int	skippedTasks()
scala.collection.Seq<Object>	stageIds()
JobExecutionStatus	status()
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

LiveJob

public LiveJob(int jobId,
               String name,
               scala.Option<java.util.Date> submissionTime,
               scala.collection.Seq<Object> stageIds,
               scala.Option<String> jobGroup,
               int numTasks)

Method Detail

jobId

public int jobId()

stageIds

public scala.collection.Seq<Object> stageIds()

activeTasks

public int activeTasks()

completedTasks

public int completedTasks()

failedTasks

public int failedTasks()

completedIndices

public org.apache.spark.util.collection.OpenHashSet<Object> completedIndices()

killedTasks

public int killedTasks()

killedSummary

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

skippedTasks

public int skippedTasks()

skippedStages

public scala.collection.immutable.Set<Object> skippedStages()

status

public JobExecutionStatus status()

completionTime

public scala.Option<java.util.Date> completionTime()

completedStages

public scala.collection.immutable.Set<Object> completedStages()

activeStages

public int activeStages()

failedStages

public int failedStages()

lastWriteTime

public long lastWriteTime()

write

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