class TaskResourceRequest extends Serializable
A task resource request. This is used in conjunction with the ResourceProfile to programmatically specify the resources needed for an RDD that will be applied at the stage level.
Use TaskResourceRequests class as a convenience API.
- Annotations
- @Evolving() @Since( "3.1.0" )
- Source
- TaskResourceRequest.scala
- Alphabetic
- By Inheritance
- TaskResourceRequest
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
TaskResourceRequest(resourceName: String, amount: Double)
- resourceName
Resource name
- amount
Amount requesting as a Double to support fractional resource requests. Valid values are less than or equal to 0.5 or whole numbers. This essentially lets you configure X number of tasks to run on a single resource, ie amount equals 0.5 translates into 2 tasks per resource address.
Value Members
- val amount: Double
-
def
equals(obj: Any): Boolean
- Definition Classes
- TaskResourceRequest → AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- TaskResourceRequest → AnyRef → Any
- val resourceName: String
-
def
toString(): String
- Definition Classes
- TaskResourceRequest → AnyRef → Any