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

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,
                   String storageLevel,
                   long memoryUsed,
                   long diskUsed)

value

public RDDPartitionInfo value()