Class LiveRDDDistribution

Object
org.apache.spark.status.LiveRDDDistribution

public class LiveRDDDistribution extends Object
  • Constructor Details

    • LiveRDDDistribution

      public LiveRDDDistribution(org.apache.spark.status.LiveExecutor exec)
  • Method Details

    • diskUsed

      public long diskUsed()
    • executorId

      public String executorId()
    • lastUpdate

      public RDDDataDistribution lastUpdate()
    • memoryUsed

      public long memoryUsed()
    • offHeapUsed

      public long offHeapUsed()
    • onHeapUsed

      public long onHeapUsed()
    • toApi

      public RDDDataDistribution toApi()