org.apache.spark.status

Class LiveExecutorStageSummary

Object

org.apache.spark.status.LiveExecutorStageSummary

public class LiveExecutorStageSummary
extends Object

Constructor Summary

Constructors

Constructor and Description
LiveExecutorStageSummary(int stageId, int attemptId, String executorId)

Method Summary

Modifier and Type	Method and Description
int	failedTasks()
boolean	isExcluded()
int	killedTasks()
long	lastWriteTime()
TaskMetrics	metrics()
org.apache.spark.executor.ExecutorMetrics	peakExecutorMetrics()
int	succeededTasks()
long	taskTime()
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

LiveExecutorStageSummary

public LiveExecutorStageSummary(int stageId,
                                int attemptId,
                                String executorId)

Method Detail

failedTasks

public int failedTasks()

isExcluded

public boolean isExcluded()

killedTasks

public int killedTasks()

metrics

public TaskMetrics metrics()

peakExecutorMetrics

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

succeededTasks

public int succeededTasks()

taskTime

public long taskTime()

lastWriteTime

public long lastWriteTime()

write

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