org.apache.spark.status

Class LiveRDD

Object

org.apache.spark.status.LiveRDD

public class LiveRDD
extends Object

Constructor Summary

Constructors

Constructor and Description
LiveRDD(RDDInfo info)

Method Summary

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)

Methods inherited from class Object

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

Constructor Detail

LiveRDD

public LiveRDD(RDDInfo info)

Method Detail

diskUsed

public long diskUsed()

distribution

public LiveRDDDistribution distribution(LiveExecutor exec)

distributionOpt

public scala.Option<LiveRDDDistribution> distributionOpt(LiveExecutor exec)

getDistributions

public scala.collection.Map<String,LiveRDDDistribution> getDistributions()

getPartitions

public scala.collection.Map<String,LiveRDDPartition> getPartitions()

info

public RDDInfo info()

memoryUsed

public long memoryUsed()

partition

public LiveRDDPartition partition(String blockName)

removeDistribution

public boolean removeDistribution(LiveExecutor exec)

removePartition

public void removePartition(String blockName)

setStorageLevel

public void setStorageLevel(String level)

storageLevel

public String storageLevel()

lastWriteTime

public long lastWriteTime()

write

public void write(org.apache.spark.status.ElementTrackingStore store,
                  long now,
                  boolean checkTriggers)