org.apache.spark.status

Class LiveResourceProfile

Object

org.apache.spark.status.LiveResourceProfile

public class LiveResourceProfile
extends Object

Constructor Summary

Constructors

Constructor and 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 and 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 Object

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

Constructor Detail

LiveResourceProfile

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

Method Detail

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)