diff options
| author | Imran Rashid <imran@quantifind.com> | 2013-01-25 10:05:26 -0800 |
|---|---|---|
| committer | Imran Rashid <imran@quantifind.com> | 2013-01-25 10:05:26 -0800 |
| commit | a1d9d1767d821c1e25e485e32d9356b12aba6a01 (patch) | |
| tree | e7c61fd6b24fea0cd49983bd5d8a44ace42bd82b | |
| parent | 1cadaa164e9f078e4ca483edb9db7fd5507c9e64 (diff) | |
| download | spark-a1d9d1767d821c1e25e485e32d9356b12aba6a01.tar.gz spark-a1d9d1767d821c1e25e485e32d9356b12aba6a01.tar.bz2 spark-a1d9d1767d821c1e25e485e32d9356b12aba6a01.zip | |
fixup 1cadaa1, changed api of map
| -rw-r--r-- | core/src/main/scala/spark/storage/StorageUtils.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/storage/StorageUtils.scala b/core/src/main/scala/spark/storage/StorageUtils.scala index 63ad5c125b..a10e3a95c6 100644 --- a/core/src/main/scala/spark/storage/StorageUtils.scala +++ b/core/src/main/scala/spark/storage/StorageUtils.scala @@ -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 |