org.apache.spark.status

Class LiveRDDPartition

Object

org.apache.spark.status.LiveRDDPartition

public class LiveRDDPartition
extends Object

Constructor Summary

Constructors

Constructor and Description
LiveRDDPartition(String blockName)

Method Summary

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

Methods inherited from class Object

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

Constructor Detail

LiveRDDPartition

public LiveRDDPartition(String blockName)

Method Detail

blockName

public String blockName()

prev

public LiveRDDPartition prev()

next

public LiveRDDPartition next()

value

public RDDPartitionInfo value()

executors

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

memoryUsed

public long memoryUsed()

diskUsed

public long diskUsed()

update

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