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()