aboutsummaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorVladimir Vladimirov <vladimir.vladimirov@magnetic.com>2015-06-29 12:03:41 -0700
committerJosh Rosen <joshrosen@databricks.com>2015-06-29 12:03:41 -0700
commit492dca3a73e70705b5d5639e8fe4640b80e78d31 (patch)
tree2bb564110a0188be74d200defcc69a1dfae8f74d /python
parenta5c2961caaafd751f11bdd406bb6885443d7572e (diff)
downloadspark-492dca3a73e70705b5d5639e8fe4640b80e78d31.tar.gz
spark-492dca3a73e70705b5d5639e8fe4640b80e78d31.tar.bz2
spark-492dca3a73e70705b5d5639e8fe4640b80e78d31.zip
[SPARK-8528] Expose SparkContext.applicationId in PySpark
Use case - we want to log applicationId (YARN in hour case) to request help with troubleshooting from the DevOps Author: Vladimir Vladimirov <vladimir.vladimirov@magnetic.com> Closes #6936 from smartkiwi/master and squashes the following commits: 870338b [Vladimir Vladimirov] this would make doctest to run in python3 0eae619 [Vladimir Vladimirov] Scala doesn't use u'...' for unicode literals 14d77a8 [Vladimir Vladimirov] stop using ELLIPSIS b4ebfc5 [Vladimir Vladimirov] addressed PR feedback - updated docstring 223a32f [Vladimir Vladimirov] fixed test - applicationId is property that returns the string 3221f5a [Vladimir Vladimirov] [SPARK-8528] added documentation for Scala 2cff090 [Vladimir Vladimirov] [SPARK-8528] add applicationId property for SparkContext object in pyspark
Diffstat (limited to 'python')
-rw-r--r--python/pyspark/context.py15
1 files changed, 15 insertions, 0 deletions
diff --git a/python/pyspark/context.py b/python/pyspark/context.py
index 90b2fffbb9..d7466729b8 100644
--- a/python/pyspark/context.py
+++ b/python/pyspark/context.py
@@ -292,6 +292,21 @@ class SparkContext(object):
return self._jsc.version()
@property
+ @ignore_unicode_prefix
+ def applicationId(self):
+ """
+ A unique identifier for the Spark application.
+ Its format depends on the scheduler implementation.
+ (i.e.
+ in case of local spark app something like 'local-1433865536131'
+ in case of YARN something like 'application_1433865536131_34483'
+ )
+ >>> sc.applicationId # doctest: +ELLIPSIS
+ u'local-...'
+ """
+ return self._jsc.sc().applicationId()
+
+ @property
def startTime(self):
"""Return the epoch time when the Spark Context was started."""
return self._jsc.startTime()