File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -823,9 +823,11 @@ class SparkContext(config: SparkConf) extends Logging {
823823 }
824824
825825 /**
826+ * :: DeveloperApi ::
826827 * Return information about what RDDs are cached, if they are in mem or on disk, how much space
827828 * they take, etc.
828829 */
830+ @ DeveloperApi
829831 def getRDDStorageInfo : Array [RDDInfo ] = {
830832 StorageUtils .rddInfoFromStorageStatus(getExecutorStorageStatus, this )
831833 }
@@ -837,8 +839,10 @@ class SparkContext(config: SparkConf) extends Logging {
837839 def getPersistentRDDs : Map [Int , RDD [_]] = persistentRdds.toMap
838840
839841 /**
842+ * :: DeveloperApi ::
840843 * Return information about blocks stored in all of the slaves
841844 */
845+ @ DeveloperApi
842846 def getExecutorStorageStatus : Array [StorageStatus ] = {
843847 env.blockManager.master.getStorageStatus
844848 }
You can’t perform that action at this time.
0 commit comments