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

Class ExecutorSummary

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

  • Method Details

    • activeTasks

      public int activeTasks()

    • addTime

      public Date addTime()

    • attributes

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

    • blacklistedInStages

      public scala.collection.immutable.Set<Object> blacklistedInStages()
      Deprecated.
      use excludedInStages instead. Since 3.1.0.

    • completedTasks

      public int completedTasks()

    • diskUsed

      public long diskUsed()

    • excludedInStages

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

    • executorLogs

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

    • failedTasks

      public int failedTasks()

    • hostPort

      public String hostPort()

    • id

      public String id()

    • isActive

      public boolean isActive()

    • isBlacklisted

      public boolean isBlacklisted()
      Deprecated.
      use isExcluded instead. Since 3.1.0.

    • isExcluded

      public boolean isExcluded()

    • maxMemory

      public long maxMemory()

    • maxTasks

      public int maxTasks()

    • memoryMetrics

      public scala.Option<MemoryMetrics> memoryMetrics()

    • memoryUsed

      public long memoryUsed()

    • peakMemoryMetrics

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

    • rddBlocks

      public int rddBlocks()

    • removeReason

      public scala.Option<String> removeReason()

    • removeTime

      public scala.Option<Date> removeTime()

    • resourceProfileId

      public int resourceProfileId()

    • resources

      public scala.collection.immutable.Map<String,ResourceInformation> resources()

    • totalCores

      public int totalCores()

    • totalDuration

      public long totalDuration()

    • totalGCTime

      public long totalGCTime()

    • totalInputBytes

      public long totalInputBytes()

    • totalShuffleRead

      public long totalShuffleRead()

    • totalShuffleWrite

      public long totalShuffleWrite()

    • totalTasks

      public int totalTasks()