aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPrashant Sharma <prashant.s@imaginea.com>2014-06-11 10:49:34 -0700
committerPatrick Wendell <pwendell@gmail.com>2014-06-11 10:49:34 -0700
commite508f599f88baaa31a3498fb0bdbafdbc303119e (patch)
treece64092e9c8bef4f6286c6456751efdf9c2902aa
parent5b754b45f301a310e9232f3a5270201ebfc16076 (diff)
downloadspark-e508f599f88baaa31a3498fb0bdbafdbc303119e.tar.gz
spark-e508f599f88baaa31a3498fb0bdbafdbc303119e.tar.bz2
spark-e508f599f88baaa31a3498fb0bdbafdbc303119e.zip
[SPARK-2108] Mark SparkContext methods that return block information as developer API's
Author: Prashant Sharma <prashant.s@imaginea.com> Closes #1047 from ScrapCodes/SPARK-2108/mark-as-dev-api and squashes the following commits: 073ee34 [Prashant Sharma] [SPARK-2108] Mark SparkContext methods that return block information as developer API's
-rw-r--r--core/src/main/scala/org/apache/spark/SparkContext.scala4
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 d721aba709..8bdaf0bf76 100644
--- a/core/src/main/scala/org/apache/spark/SparkContext.scala
+++ b/core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -823,9 +823,11 @@ class SparkContext(config: SparkConf) extends Logging {
}
/**
+ * :: DeveloperApi ::
* Return information about what RDDs are cached, if they are in mem or on disk, how much space
* they take, etc.
*/
+ @DeveloperApi
def getRDDStorageInfo: Array[RDDInfo] = {
StorageUtils.rddInfoFromStorageStatus(getExecutorStorageStatus, this)
}
@@ -837,8 +839,10 @@ class SparkContext(config: SparkConf) extends Logging {
def getPersistentRDDs: Map[Int, RDD[_]] = persistentRdds.toMap
/**
+ * :: DeveloperApi ::
* Return information about blocks stored in all of the slaves
*/
+ @DeveloperApi
def getExecutorStorageStatus: Array[StorageStatus] = {
env.blockManager.master.getStorageStatus
}