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, scala.collection.Seq<String> jobTags, int numTasks, scala.Option<Object> sqlExecutionId)

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()
scala.Option<java.util.Date>	submissionTime()
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,
               scala.collection.Seq<String> jobTags,
               int numTasks,
               scala.Option<Object> sqlExecutionId)

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()

submissionTime

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

lastWriteTime

public long lastWriteTime()

write

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