Package org.apache.spark.status

Class LiveRDDPartition

Object

org.apache.spark.status.LiveRDDPartition

public class LiveRDDPartition
extends Object

Data about a single partition of a cached RDD. The RDD storage level is used to compute the effective storage level of the partition, which takes into account the storage actually being used by the partition in the executors, and thus may differ from the storage level requested by the application.

Constructor Summary

Constructors

Constructor	Description
LiveRDDPartition(String blockName, StorageLevel rddLevel)

Method Summary

Modifier and Type	Method	Description
String	blockName()
long	diskUsed()
scala.collection.Seq<String>	executors()
long	memoryUsed()
LiveRDDPartition	next()
LiveRDDPartition	prev()
void	update(scala.collection.Seq<String> executors, long memoryUsed, long diskUsed)
RDDPartitionInfo	value()

Methods inherited from class java.lang.Object

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

Constructor Details

LiveRDDPartition

public LiveRDDPartition(String blockName,
 StorageLevel rddLevel)

Method Details

blockName

public String blockName()

diskUsed

public long diskUsed()

executors

public scala.collection.Seq<String> executors()

memoryUsed

public long memoryUsed()

next

public LiveRDDPartition next()

prev

public LiveRDDPartition prev()

update

public void update(scala.collection.Seq<String> executors,
 long memoryUsed,
 long diskUsed)

value

public RDDPartitionInfo value()