Skip to content

Commit

Permalink
Other variable name changes
Browse files Browse the repository at this point in the history
  • Loading branch information
tgravescs committed Apr 22, 2020
1 parent 89be02e commit 354fb0c
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
8 changes: 4 additions & 4 deletions python/pyspark/rdd.py
Expand Up @@ -243,7 +243,7 @@ def __init__(self, jrdd, ctx, jrdd_deserializer=AutoBatchedSerializer(PickleSeri
self._jrdd = jrdd
self.is_cached = False
self.is_checkpointed = False
self.has_resourceProfile = False
self.has_resource_profile = False
self.ctx = ctx
self._jrdd_deserializer = jrdd_deserializer
self._id = jrdd.id()
Expand Down Expand Up @@ -2482,7 +2482,7 @@ def withResources(self, profile):
.. versionadded:: 3.1.0
"""
self.has_resourceProfile = True
self.has_resource_profile = True
if profile._java_resource_profile is not None:
jrp = profile._java_resource_profile
else:
Expand Down Expand Up @@ -2616,7 +2616,7 @@ def pipeline_func(split, iterator):
self._prev_jrdd = prev._prev_jrdd # maintain the pipeline
self._prev_jrdd_deserializer = prev._prev_jrdd_deserializer
self.is_cached = False
self.has_resourceProfile = False
self.has_resource_profile = False
self.is_checkpointed = False
self.ctx = prev.ctx
self.prev = prev
Expand Down Expand Up @@ -2659,7 +2659,7 @@ def id(self):
return self._id

def _is_pipelinable(self):
return not (self.is_cached or self.is_checkpointed or self.has_resourceProfile)
return not (self.is_cached or self.is_checkpointed or self.has_resource_profile)

def _is_barrier(self):
return self.is_barrier
Expand Down
4 changes: 2 additions & 2 deletions python/pyspark/resource/executorrequests.py
Expand Up @@ -83,8 +83,8 @@ class ExecutorResourceRequests(object):
.. note:: Evolving
A set of Executor resource requests. This is used in conjunction with the
ResourceProfileBuilder to programmatically specify the resources needed for an RDD
that will be applied at the stage level.
:class:`pyspark.resource.ResourceProfileBuilder` to programmatically specify the
resources needed for an RDD that will be applied at the stage level.
.. versionadded:: 3.1.0
"""
Expand Down

0 comments on commit 354fb0c

Please sign in to comment.