Package org.apache.spark.status.api.v1

Class StageData

Object
org.apache.spark.status.api.v1.StageData
public class StageData extends Object

  • Method Details

    • accumulatorUpdates

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

    • attemptId

      public int attemptId()

    • completionTime

      public scala.Option<Date> completionTime()

    • description

      public scala.Option<String> description()

    • details

      public String details()

    • diskBytesSpilled

      public long diskBytesSpilled()

    • executorCpuTime

      public long executorCpuTime()

    • executorDeserializeCpuTime

      public long executorDeserializeCpuTime()

    • executorDeserializeTime

      public long executorDeserializeTime()

    • executorMetricsDistributions

      public scala.Option<ExecutorMetricsDistributions> executorMetricsDistributions()

    • executorRunTime

      public long executorRunTime()

    • executorSummary

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

    • failureReason

      public scala.Option<String> failureReason()

    • firstTaskLaunchedTime

      public scala.Option<Date> firstTaskLaunchedTime()

    • inputBytes

      public long inputBytes()

    • inputRecords

      public long inputRecords()

    • isShufflePushEnabled

      public boolean isShufflePushEnabled()

    • jvmGcTime

      public long jvmGcTime()

    • killedTasksSummary

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

    • memoryBytesSpilled

      public long memoryBytesSpilled()

    • name

      public String name()

    • numActiveTasks

      public int numActiveTasks()

    • numCompleteTasks

      public int numCompleteTasks()

    • numCompletedIndices

      public int numCompletedIndices()

    • numFailedTasks

      public int numFailedTasks()

    • numKilledTasks

      public int numKilledTasks()

    • numTasks

      public int numTasks()

    • outputBytes

      public long outputBytes()

    • outputRecords

      public long outputRecords()

    • peakExecutionMemory

      public long peakExecutionMemory()

    • peakExecutorMetrics

      public scala.Option<org.apache.spark.executor.ExecutorMetrics> peakExecutorMetrics()

    • rddIds

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

    • resourceProfileId

      public int resourceProfileId()

    • resultSerializationTime

      public long resultSerializationTime()

    • resultSize

      public long resultSize()

    • schedulingPool

      public String schedulingPool()

    • shuffleCorruptMergedBlockChunks

      public long shuffleCorruptMergedBlockChunks()

    • shuffleFetchWaitTime

      public long shuffleFetchWaitTime()

    • shuffleLocalBlocksFetched

      public long shuffleLocalBlocksFetched()

    • shuffleLocalBytesRead

      public long shuffleLocalBytesRead()

    • shuffleMergedFetchFallbackCount

      public long shuffleMergedFetchFallbackCount()

    • shuffleMergedLocalBlocksFetched

      public long shuffleMergedLocalBlocksFetched()

    • shuffleMergedLocalBytesRead

      public long shuffleMergedLocalBytesRead()

    • shuffleMergedLocalChunksFetched

      public long shuffleMergedLocalChunksFetched()

    • shuffleMergedRemoteBlocksFetched

      public long shuffleMergedRemoteBlocksFetched()

    • shuffleMergedRemoteBytesRead

      public long shuffleMergedRemoteBytesRead()

    • shuffleMergedRemoteChunksFetched

      public long shuffleMergedRemoteChunksFetched()

    • shuffleMergedRemoteReqsDuration

      public long shuffleMergedRemoteReqsDuration()

    • shuffleMergersCount

      public int shuffleMergersCount()

    • shuffleReadBytes

      public long shuffleReadBytes()

    • shuffleReadRecords

      public long shuffleReadRecords()

    • shuffleRemoteBlocksFetched

      public long shuffleRemoteBlocksFetched()

    • shuffleRemoteBytesRead

      public long shuffleRemoteBytesRead()

    • shuffleRemoteBytesReadToDisk

      public long shuffleRemoteBytesReadToDisk()

    • shuffleRemoteReqsDuration

      public long shuffleRemoteReqsDuration()

    • shuffleWriteBytes

      public long shuffleWriteBytes()

    • shuffleWriteRecords

      public long shuffleWriteRecords()

    • shuffleWriteTime

      public long shuffleWriteTime()

    • speculationSummary

      public scala.Option<SpeculationStageSummary> speculationSummary()

    • stageId

      public int stageId()

    • status

      public StageStatus status()

    • submissionTime

      public scala.Option<Date> submissionTime()

    • taskMetricsDistributions

      public scala.Option<TaskMetricDistributions> taskMetricsDistributions()

    • tasks

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