ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

fixup 1cadaa1, changed api of map

Browse source
This commit is contained in:
Imran Rashid 2013-01-25 10:05:26 -08:00
parent 1cadaa164e
commit a1d9d1767d
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
core/src/main/scala/spark/storage/StorageUtils.scala
View file

@ -56,8 +56,8 @@ object StorageUtils {
// Find the id of the RDD, e.g. rdd_1 => 1
val rddId = rddKey.split("_").last.toInt
// Get the friendly name for the rdd, if available.
val rddName = Option(sc.persistentRdds.get(rddId).name).getOrElse(rddKey)
val rddStorageLevel = sc.persistentRdds.get(rddId).getStorageLevel
val rddName = Option(sc.persistentRdds(rddId).name).getOrElse(rddKey)
val rddStorageLevel = sc.persistentRdds(rddId).getStorageLevel
RDDInfo(rddId, rddName, rddStorageLevel, rddBlocks.length, memSize, diskSize)
}.toArray