public class ResourceProfileBuilder
extends Object
ResourceProfile
to associate with an RDD.
A ResourceProfile
allows the user to specify executor and task resource requirements
for an RDD that will get applied during a stage. This allows the user to change the resource
requirements between stages.
Constructor and Description |
---|
ResourceProfileBuilder() |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
build() |
ResourceProfileBuilder |
clearExecutorResourceRequests() |
ResourceProfileBuilder |
clearTaskResourceRequests() |
scala.collection.immutable.Map<String,ExecutorResourceRequest> |
executorResources() |
java.util.Map<String,ExecutorResourceRequest> |
executorResourcesJMap()
(Java-specific) gets a Java Map of resources to ExecutorResourceRequest
|
ResourceProfileBuilder |
require(ExecutorResourceRequests requests)
Add executor resource requests
|
ResourceProfileBuilder |
require(TaskResourceRequests requests)
Add task resource requests
|
scala.collection.immutable.Map<String,TaskResourceRequest> |
taskResources() |
java.util.Map<String,TaskResourceRequest> |
taskResourcesJMap()
(Java-specific) gets a Java Map of resources to TaskResourceRequest
|
String |
toString() |
public ResourceProfile build()
public ResourceProfileBuilder clearExecutorResourceRequests()
public ResourceProfileBuilder clearTaskResourceRequests()
public scala.collection.immutable.Map<String,ExecutorResourceRequest> executorResources()
public java.util.Map<String,ExecutorResourceRequest> executorResourcesJMap()
public ResourceProfileBuilder require(ExecutorResourceRequests requests)
requests
- The detailed executor resource requests, see ExecutorResourceRequests
public ResourceProfileBuilder require(TaskResourceRequests requests)
requests
- The detailed task resource requests, see TaskResourceRequest
public scala.collection.immutable.Map<String,TaskResourceRequest> taskResources()
public java.util.Map<String,TaskResourceRequest> taskResourcesJMap()
public String toString()
toString
in class Object