org.apache.spark.status.api.v1
Class StageData

Object
  org.apache.spark.status.api.v1.StageData

public class StageData
extends Object

Method Summary

scala.collection.Seq<AccumulableInfo>	accumulatorUpdates()
int	attemptId()
String	details()
long	diskBytesSpilled()
long	executorRunTime()
scala.Option<scala.collection.Map<String,ExecutorStageSummary>>	executorSummary()
long	inputBytes()
long	inputRecords()
long	memoryBytesSpilled()
String	name()
int	numActiveTasks()
int	numCompleteTasks()
int	numFailedTasks()
long	outputBytes()
long	outputRecords()
String	schedulingPool()
long	shuffleReadBytes()
long	shuffleReadRecords()
long	shuffleWriteBytes()
long	shuffleWriteRecords()
int	stageId()
StageStatus	status()
scala.Option<scala.collection.Map<Object,TaskData>>	tasks()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

status

public StageStatus status()

stageId

public int stageId()

attemptId

public int attemptId()

numActiveTasks

public int numActiveTasks()

numCompleteTasks

public int numCompleteTasks()

numFailedTasks

public int numFailedTasks()

executorRunTime

public long executorRunTime()

inputBytes

public long inputBytes()

inputRecords

public long inputRecords()

outputBytes

public long outputBytes()

outputRecords

public long outputRecords()

shuffleReadBytes

public long shuffleReadBytes()

shuffleReadRecords

public long shuffleReadRecords()

shuffleWriteBytes

public long shuffleWriteBytes()

shuffleWriteRecords

public long shuffleWriteRecords()

memoryBytesSpilled

public long memoryBytesSpilled()

diskBytesSpilled

public long diskBytesSpilled()

name

public String name()

details

public String details()

schedulingPool

public String schedulingPool()

accumulatorUpdates

public scala.collection.Seq<AccumulableInfo> accumulatorUpdates()

tasks

public scala.Option<scala.collection.Map<Object,TaskData>> tasks()

executorSummary

public scala.Option<scala.collection.Map<String,ExecutorStageSummary>> executorSummary()