public class LiveRDD
extends Object
Modifier and Type | Method and Description |
---|---|
long |
diskUsed() |
LiveRDDDistribution |
distribution(LiveExecutor exec) |
scala.Option<LiveRDDDistribution> |
distributionOpt(LiveExecutor exec) |
scala.collection.Map<String,LiveRDDDistribution> |
getDistributions() |
scala.collection.Map<String,LiveRDDPartition> |
getPartitions() |
RDDInfo |
info() |
long |
lastWriteTime() |
long |
memoryUsed() |
LiveRDDPartition |
partition(String blockName) |
boolean |
removeDistribution(LiveExecutor exec) |
void |
removePartition(String blockName) |
void |
setStorageLevel(String level) |
String |
storageLevel() |
void |
write(org.apache.spark.status.ElementTrackingStore store,
long now,
boolean checkTriggers) |
public LiveRDD(RDDInfo info)
public RDDInfo info()
public String storageLevel()
public long memoryUsed()
public long diskUsed()
public void setStorageLevel(String level)
public LiveRDDPartition partition(String blockName)
public void removePartition(String blockName)
public LiveRDDDistribution distribution(LiveExecutor exec)
public boolean removeDistribution(LiveExecutor exec)
public scala.Option<LiveRDDDistribution> distributionOpt(LiveExecutor exec)
public scala.collection.Map<String,LiveRDDPartition> getPartitions()
public scala.collection.Map<String,LiveRDDDistribution> getDistributions()
public long lastWriteTime()
public void write(org.apache.spark.status.ElementTrackingStore store, long now, boolean checkTriggers)