Repository: spark Updated Branches: refs/heads/master 1fcefef06 -> f24316e6d
[SPARK-10458] [SPARK CORE] Added isStopped() method in SparkContext Added isStopped() method in SparkContext Author: Madhusudanan Kandasamy <madhusuda...@in.ibm.com> Closes #8749 from kmadhugit/SPARK-10458. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/f24316e6 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/f24316e6 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/f24316e6 Branch: refs/heads/master Commit: f24316e6d928c263cbf3872edd97982059c3db22 Parents: 1fcefef Author: Madhusudanan Kandasamy <madhusuda...@in.ibm.com> Authored: Tue Sep 22 00:03:48 2015 -0700 Committer: Andrew Or <and...@databricks.com> Committed: Tue Sep 22 00:03:48 2015 -0700 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/SparkContext.scala | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/f24316e6/core/src/main/scala/org/apache/spark/SparkContext.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index ebd8e94..967fec9 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 --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org