Package 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	Description
RDDInfo(int id, String name, int numPartitions, StorageLevel storageLevel, boolean isBarrier, scala.collection.immutable.Seq<Object> parentIds, String callSite, scala.Option<org.apache.spark.rdd.RDDOperationScope> scope, scala.Enumeration.Value outputDeterministicLevel)

Method Summary

Modifier and Type	Method	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.Enumeration.Value	outputDeterministicLevel()
scala.collection.immutable.Seq<Object>	parentIds()
scala.Option<org.apache.spark.rdd.RDDOperationScope>	scope()
StorageLevel	storageLevel()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.math.Ordered

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

Constructor Details

RDDInfo

public RDDInfo(int id,
 String name,
 int numPartitions,
 StorageLevel storageLevel,
 boolean isBarrier,
 scala.collection.immutable.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.immutable.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>