org.apache.spark.storage
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 Summary

RDDInfo(int id, String name, int numPartitions, StorageLevel storageLevel, scala.collection.Seq<Object> parentIds, scala.Option<org.apache.spark.rdd.RDDOperationScope> scope)

Method Summary

int	compare(RDDInfo that)
long	diskSize()
long	externalBlockStoreSize()
static RDDInfo	fromRdd(RDD<?> rdd)
int	id()
boolean	isCached()
long	memSize()
String	name()
int	numCachedPartitions()
int	numPartitions()
scala.collection.Seq<Object>	parentIds()
scala.Option<org.apache.spark.rdd.RDDOperationScope>	scope()
StorageLevel	storageLevel()
String	toString()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.math.Ordered

$greater, $greater$eq, $less, $less$eq, compareTo

Constructor Detail

RDDInfo

public RDDInfo(int id,
               String name,
               int numPartitions,
               StorageLevel storageLevel,
               scala.collection.Seq<Object> parentIds,
               scala.Option<org.apache.spark.rdd.RDDOperationScope> scope)

Method Detail

fromRdd

public static RDDInfo fromRdd(RDD<?> rdd)

id

public int id()

name

public String name()

numPartitions

public int numPartitions()

storageLevel

public StorageLevel storageLevel()

parentIds

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

scope

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

numCachedPartitions

public int numCachedPartitions()

memSize

public long memSize()

diskSize

public long diskSize()

externalBlockStoreSize

public long externalBlockStoreSize()

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>