org.apache.spark.status

Class LiveRDDDistribution

Object

org.apache.spark.status.LiveRDDDistribution

public class LiveRDDDistribution
extends Object

Constructor Summary

Constructors

Constructor and Description
LiveRDDDistribution(LiveExecutor exec)

Method Summary

Modifier and Type	Method and Description
long	diskUsed()
String	executorId()
RDDDataDistribution	lastUpdate()
long	memoryUsed()
long	offHeapUsed()
long	onHeapUsed()
RDDDataDistribution	toApi()

Methods inherited from class Object

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

Constructor Detail

LiveRDDDistribution

public LiveRDDDistribution(LiveExecutor exec)

Method Detail

diskUsed

public long diskUsed()

executorId

public String executorId()

lastUpdate

public RDDDataDistribution lastUpdate()

memoryUsed

public long memoryUsed()

offHeapUsed

public long offHeapUsed()

onHeapUsed

public long onHeapUsed()

toApi

public RDDDataDistribution toApi()