Package org.apache.spark.status

Class LiveResourceProfile

Object

org.apache.spark.status.LiveResourceProfile

public class LiveResourceProfile
extends Object

Constructor Summary

Constructors

Constructor	Description
LiveResourceProfile(int resourceProfileId, scala.collection.immutable.Map<String,ExecutorResourceRequest> executorResources, scala.collection.immutable.Map<String,TaskResourceRequest> taskResources, scala.Option<Object> maxTasksPerExecutor)

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.Map<String,ExecutorResourceRequest>	executorResources()
long	lastWriteTime()
scala.Option<Object>	maxTasksPerExecutor()
int	resourceProfileId()
scala.collection.immutable.Map<String,TaskResourceRequest>	taskResources()
ResourceProfileInfo	toApi()
void	write(org.apache.spark.status.ElementTrackingStore store, long now, boolean checkTriggers)

Methods inherited from class java.lang.Object

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

Constructor Details

LiveResourceProfile

public LiveResourceProfile(int resourceProfileId,
 scala.collection.immutable.Map<String,ExecutorResourceRequest> executorResources,
 scala.collection.immutable.Map<String,TaskResourceRequest> taskResources,
 scala.Option<Object> maxTasksPerExecutor)

Method Details

executorResources

public scala.collection.immutable.Map<String,ExecutorResourceRequest> executorResources()

maxTasksPerExecutor

public scala.Option<Object> maxTasksPerExecutor()

resourceProfileId

public int resourceProfileId()

taskResources

public scala.collection.immutable.Map<String,TaskResourceRequest> taskResources()

toApi

public ResourceProfileInfo toApi()

lastWriteTime

public long lastWriteTime()

write

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