public class LiveRDDPartition
extends Object
Constructor and Description |
---|
LiveRDDPartition(String blockName,
StorageLevel rddLevel) |
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,
long memoryUsed,
long diskUsed) |
RDDPartitionInfo |
value() |
public LiveRDDPartition(String blockName, StorageLevel rddLevel)
public String blockName()
public long diskUsed()
public scala.collection.Seq<String> executors()
public long memoryUsed()
public LiveRDDPartition next()
public LiveRDDPartition prev()
public void update(scala.collection.Seq<String> executors, long memoryUsed, long diskUsed)
public RDDPartitionInfo value()