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<String> description, 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<String> description,
               scala.Option<java.util.Date> submissionTime,
               scala.collection.Seq<Object> stageIds,
               scala.Option<String> jobGroup,
               int numTasks)

Method Detail

activeStages

public int activeStages()

activeTasks

public int activeTasks()

completedIndices

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

completedStages

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

completedTasks

public int completedTasks()

completionTime

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

failedStages

public int failedStages()

failedTasks

public int failedTasks()

jobId

public int jobId()

killedSummary

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

killedTasks

public int killedTasks()

skippedStages

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

skippedTasks

public int skippedTasks()

stageIds

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

status

public JobExecutionStatus status()

lastWriteTime

public long lastWriteTime()

write

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