diff options
| author | Prabin Banka <prabin.banka@imaginea.com> | 2014-03-06 12:45:27 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-03-06 12:45:27 -0800 |
| commit | 3d3acef0474b6dc21f1b470ea96079a491e58b75 (patch) | |
| tree | 97ebf321dc9d58032599d1216fa7f675f0daa287 /python/pyspark/rdd.py | |
| parent | 3eb009f362993dbe43028419c2d48011111a200d (diff) | |
| download | spark-3d3acef0474b6dc21f1b470ea96079a491e58b75.tar.gz spark-3d3acef0474b6dc21f1b470ea96079a491e58b75.tar.bz2 spark-3d3acef0474b6dc21f1b470ea96079a491e58b75.zip | |
SPARK-1187, Added missing Python APIs
The following Python APIs are added,
RDD.id()
SparkContext.setJobGroup()
SparkContext.setLocalProperty()
SparkContext.getLocalProperty()
SparkContext.sparkUser()
was raised earlier as a part of apache/incubator-spark#486
Author: Prabin Banka <prabin.banka@imaginea.com>
Closes #75 from prabinb/python-api-backup and squashes the following commits:
cc3c6cd [Prabin Banka] Added missing Python APIs
Diffstat (limited to 'python/pyspark/rdd.py')
| -rw-r--r-- | python/pyspark/rdd.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index be23f87f5e..097a0a236b 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -95,6 +95,13 @@ class RDD(object): self.is_checkpointed = False self.ctx = ctx self._jrdd_deserializer = jrdd_deserializer + self._id = jrdd.id() + + def id(self): + """ + A unique ID for this RDD (within its SparkContext). + """ + return self._id def __repr__(self): return self._jrdd.toString() |