diff options
| author | Evan Chan <ev@ooyala.com> | 2013-07-23 09:50:13 -0700 |
|---|---|---|
| committer | Evan Chan <ev@ooyala.com> | 2013-07-23 09:50:13 -0700 |
| commit | 4830e225624091fa836012651420cf2b5b97dcca (patch) | |
| tree | 7b4a774ed64ae2a16f159d7c89cdb08e9b9fc0ae /core | |
| parent | 2c2bfbe294c0082520c80a01562a2dbeeba63b7a (diff) | |
| download | spark-4830e225624091fa836012651420cf2b5b97dcca.tar.gz spark-4830e225624091fa836012651420cf2b5b97dcca.tar.bz2 spark-4830e225624091fa836012651420cf2b5b97dcca.zip | |
Rename method per rxin feedback
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/SparkContext.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/SparkContext.scala b/core/src/main/scala/spark/SparkContext.scala index 0fb7dfa810..24ba605646 100644 --- a/core/src/main/scala/spark/SparkContext.scala +++ b/core/src/main/scala/spark/SparkContext.scala @@ -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 |