org.apache.spark.storage

Class RDDInfo

java.lang.Object

org.apache.spark.storage.RDDInfo

All Implemented Interfaces:

java.lang.Comparable<RDDInfo>, scala.math.Ordered<RDDInfo>

public class RDDInfo
extends java.lang.Object
implements scala.math.Ordered<RDDInfo>

Constructor Summary

Constructors

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

Method Summary

Methods

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

Methods inherited from class java.lang.Object

clone, equals, finalize, 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,
       java.lang.String name,
       int numPartitions,
       StorageLevel storageLevel,
       scala.collection.Seq<java.lang.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 java.lang.String name()

numPartitions

public int numPartitions()

storageLevel

public StorageLevel storageLevel()

parentIds

public scala.collection.Seq<java.lang.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 java.lang.String toString()

Overrides:

toString in class java.lang.Object

compare

public int compare(RDDInfo that)

Specified by:

compare in interface scala.math.Ordered<RDDInfo>