diff options
| author | Madhusudanan Kandasamy <madhusudanan@in.ibm.com> | 2015-09-22 00:03:48 -0700 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2015-09-22 00:03:48 -0700 |
| commit | f24316e6d928c263cbf3872edd97982059c3db22 (patch) | |
| tree | 76a92910f9b0f173f9be41773372e7d476626e76 | |
| parent | 1fcefef06950e2f03477282368ca835bbf40ff24 (diff) | |
| download | spark-f24316e6d928c263cbf3872edd97982059c3db22.tar.gz spark-f24316e6d928c263cbf3872edd97982059c3db22.tar.bz2 spark-f24316e6d928c263cbf3872edd97982059c3db22.zip | |
[SPARK-10458] [SPARK CORE] Added isStopped() method in SparkContext
Added isStopped() method in SparkContext
Author: Madhusudanan Kandasamy <madhusudanan@in.ibm.com>
Closes #8749 from kmadhugit/SPARK-10458.
| -rw-r--r-- | core/src/main/scala/org/apache/spark/SparkContext.scala | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index ebd8e946ee..967fec9f42 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -265,6 +265,10 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli val tachyonFolderName = externalBlockStoreFolderName def isLocal: Boolean = (master == "local" || master.startsWith("local[")) + /** + * @return true if context is stopped or in the midst of stopping. + */ + def isStopped: Boolean = stopped.get() // An asynchronous listener bus for Spark events private[spark] val listenerBus = new LiveListenerBus |