diff options
| author | Imran Rashid <imran@quantifind.com> | 2013-02-01 09:55:25 -0800 |
|---|---|---|
| committer | Imran Rashid <imran@quantifind.com> | 2013-02-01 09:55:25 -0800 |
| commit | c6190067ae40cf457b7f2e58619904b6fd2b1cb6 (patch) | |
| tree | a0d760db62759c10f096fa0f8eabd9afed315ba1 /core/src | |
| parent | 8a0a5ed53353ad6aa5656eb729d55ca7af2ab096 (diff) | |
| download | spark-c6190067ae40cf457b7f2e58619904b6fd2b1cb6.tar.gz spark-c6190067ae40cf457b7f2e58619904b6fd2b1cb6.tar.bz2 spark-c6190067ae40cf457b7f2e58619904b6fd2b1cb6.zip | |
remove unneeded (and unused) filter on block info
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/spark/storage/StorageUtils.scala | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/storage/StorageUtils.scala b/core/src/main/scala/spark/storage/StorageUtils.scala index 5367b74bb6..5f72b67b2c 100644 --- a/core/src/main/scala/spark/storage/StorageUtils.scala +++ b/core/src/main/scala/spark/storage/StorageUtils.scala @@ -43,8 +43,6 @@ object StorageUtils { /* Given a list of BlockStatus objets, returns information for each RDD */ def rddInfoFromBlockStatusList(infos: Map[String, BlockStatus], sc: SparkContext) : Array[RDDInfo] = { - // Find all RDD Blocks (ignore broadcast variables) - val rddBlocks = infos.filterKeys(_.startsWith("rdd")) // Group by rddId, ignore the partition name val groupedRddBlocks = infos.groupBy { case(k, v) => |