Package org.apache.spark.status

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