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, scala.collection.Seq<Object> parentIds, String callSite, scala.Option<org.apache.spark.rdd.RDDOperationScope> scope)

Method Summary

Modifier and Type	Method and Description
static boolean	$greater(A that)
static boolean	$greater$eq(A that)
static boolean	$less(A that)
static boolean	$less$eq(A that)
String	callSite()
int	compare(RDDInfo that)
static int	compareTo(A 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,
               String callSite,
               scala.Option<org.apache.spark.rdd.RDDOperationScope> scope)

Method Detail

fromRdd

public static RDDInfo fromRdd(RDD<?> rdd)

$less

public static boolean $less(A that)

$greater

public static boolean $greater(A that)

$less$eq

public static boolean $less$eq(A that)

$greater$eq

public static boolean $greater$eq(A that)

compareTo

public static int compareTo(A that)

id

public int id()

name

public String name()

numPartitions

public int numPartitions()

storageLevel

public StorageLevel storageLevel()

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

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>