File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -2488,10 +2488,12 @@ def _is_barrier(self):
24882488 def withResources (self , profile ):
24892489 """
24902490 .. note:: Experimental
2491+
24912492 Specify a ResourceProfile to use when calculating this RDD. This is only supported on
24922493 certain cluster managers and currently requires dynamic allocation to be enabled.
24932494 It will result in new executors with the resources specified being acquired to
24942495 calculate the RDD.
2496+
24952497 .. versionadded:: 3.0.0
24962498 """
24972499 self .has_resourceProfile = True
@@ -2501,8 +2503,10 @@ def withResources(self, profile):
25012503 def getResourceProfile (self ):
25022504 """
25032505 .. note:: Experimental
2506+
25042507 Get the ResourceProfile specified with this RDD or None if it wasn't specified.
25052508 :return: the user specified ResourceProfile or null if none was specified
2509+
25062510 .. versionadded:: 3.0.0
25072511 """
25082512 return ResourceProfile (self ._jrdd .getResourceProfile ())
You can’t perform that action at this time.
0 commit comments