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

Constructors

Constructor and Description
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)

Method Summary

Modifier and Type	Method and Description
String	callSite()
int	compare(RDDInfo that)
long	diskSize()
static RDDInfo	fromRdd(RDD<?> rdd)
int	id()
boolean	isBarrier()
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, $init$, $less, $less$eq, compareTo, orderingToOrdered

Constructor Detail

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)

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

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

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>