Skip to content
Snippets Groups Projects
Commit 4830e225 authored by Evan Chan's avatar Evan Chan
Browse files

Rename method per rxin feedback

parent 2c2bfbe2
No related branches found
No related tags found
No related merge requests found
......@@ -547,10 +547,10 @@ class SparkContext(
}
/**
* Returns an immutable map of RDDs that have marked themselves as cached via cache() call.
* Returns an immutable map of RDDs that have marked themselves as persistent via cache() call.
* Note that this does not necessarily mean the caching or computation was successful.
*/
def getCachedRDDs: Map[Int, RDD[_]] = persistentRdds.toMap
def getPersistentRDDs: Map[Int, RDD[_]] = persistentRdds.toMap
def getStageInfo: Map[Stage,StageInfo] = {
dagScheduler.stageToInfos
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment