org.apache.spark.status

Class LiveStage

Object

org.apache.spark.status.LiveStage

public class LiveStage
extends Object

Constructor Summary

Constructors

Constructor and Description
LiveStage(StageInfo info)

Method Summary

Modifier and Type	Method and Description
int	activeTasks()
scala.collection.mutable.Map<String,Object>	activeTasksPerExecutor()
boolean	cleaning()
org.apache.spark.util.collection.OpenHashSet<Object>	completedIndices()
int	completedTasks()
scala.Option<String>	description()
scala.collection.immutable.HashSet<String>	excludedExecutors()
scala.collection.mutable.HashMap<String,LiveExecutorStageSummary>	executorSummaries()
LiveExecutorStageSummary	executorSummary(String executorId)
int	failedTasks()
long	firstLaunchTime()
StageInfo	info()
scala.collection.immutable.Set<Object>	jobIds()
scala.collection.Seq<LiveJob>	jobs()
scala.collection.immutable.Map<String,Object>	killedSummary()
int	killedTasks()
long	lastWriteTime()
scala.collection.immutable.Map<String,Object>	localitySummary()
TaskMetrics	metrics()
org.apache.spark.executor.ExecutorMetrics	peakExecutorMetrics()
java.util.concurrent.atomic.AtomicInteger	savedTasks()
String	schedulingPool()
LiveSpeculationStageSummary	speculationStageSummary()
StageStatus	status()
StageData	toApi()
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

LiveStage

public LiveStage(StageInfo info)

Method Detail

activeTasks

public int activeTasks()

activeTasksPerExecutor

public scala.collection.mutable.Map<String,Object> activeTasksPerExecutor()

cleaning

public boolean cleaning()

completedIndices

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

completedTasks

public int completedTasks()

description

public scala.Option<String> description()

excludedExecutors

public scala.collection.immutable.HashSet<String> excludedExecutors()

executorSummaries

public scala.collection.mutable.HashMap<String,LiveExecutorStageSummary> executorSummaries()

executorSummary

public LiveExecutorStageSummary executorSummary(String executorId)

failedTasks

public int failedTasks()

firstLaunchTime

public long firstLaunchTime()

info

public StageInfo info()

jobIds

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

jobs

public scala.collection.Seq<LiveJob> jobs()

killedSummary

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

killedTasks

public int killedTasks()

localitySummary

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

metrics

public TaskMetrics metrics()

peakExecutorMetrics

public org.apache.spark.executor.ExecutorMetrics peakExecutorMetrics()

savedTasks

public java.util.concurrent.atomic.AtomicInteger savedTasks()

schedulingPool

public String schedulingPool()

speculationStageSummary

public LiveSpeculationStageSummary speculationStageSummary()

status

public StageStatus status()

toApi

public StageData toApi()

lastWriteTime

public long lastWriteTime()

write

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