Class RDDInfo

Object
org.apache.spark.storage.RDDInfo
All Implemented Interfaces:
Comparable<RDDInfo>, scala.math.Ordered<RDDInfo>

public class RDDInfo extends Object implements scala.math.Ordered<RDDInfo>
  • Constructor Details

    • RDDInfo

      public RDDInfo(int id, String name, int numPartitions, StorageLevel storageLevel, boolean isBarrier, scala.collection.Seq<Object> parentIds, String callSite, scala.Option<org.apache.spark.rdd.RDDOperationScope> scope, scala.Enumeration.Value outputDeterministicLevel)
  • Method Details

    • fromRdd

      public static RDDInfo fromRdd(RDD<?> rdd)
    • id

      public int id()
    • name

      public String name()
    • numPartitions

      public int numPartitions()
    • storageLevel

      public StorageLevel storageLevel()
    • isBarrier

      public boolean isBarrier()
    • parentIds

      public scala.collection.Seq<Object> parentIds()
    • callSite

      public String callSite()
    • scope

      public scala.Option<org.apache.spark.rdd.RDDOperationScope> scope()
    • outputDeterministicLevel

      public scala.Enumeration.Value outputDeterministicLevel()
    • numCachedPartitions

      public int numCachedPartitions()
    • memSize

      public long memSize()
    • diskSize

      public long diskSize()
    • isCached

      public boolean isCached()
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • compare

      public int compare(RDDInfo that)
      Specified by:
      compare in interface scala.math.Ordered<RDDInfo>