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

executorId

public String executorId()

memoryUsed

public long memoryUsed()

diskUsed

public long diskUsed()

onHeapUsed

public long onHeapUsed()

offHeapUsed

public long offHeapUsed()

lastUpdate

public RDDDataDistribution lastUpdate()

toApi

public RDDDataDistribution toApi()