diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-07-12 19:32:35 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-07-12 19:32:35 -0700 |
| commit | 08150f19abcf08f2a18305080b08736fb8a33a12 (patch) | |
| tree | d1980f8bc6f055edb12923413ee3f199c93cb268 /core | |
| parent | 6855338e1400638188358a7d7926eb86f668c160 (diff) | |
| download | spark-08150f19abcf08f2a18305080b08736fb8a33a12.tar.gz spark-08150f19abcf08f2a18305080b08736fb8a33a12.tar.bz2 spark-08150f19abcf08f2a18305080b08736fb8a33a12.zip | |
Minor style fix
Diffstat (limited to 'core')
| -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 3e7fa287e5..aca16f533a 100644 --- a/core/src/main/scala/spark/storage/StorageUtils.scala +++ b/core/src/main/scala/spark/storage/StorageUtils.scala @@ -47,8 +47,8 @@ object StorageUtils { /* Returns a map of blocks to their locations, compiled from a list of StorageStatus objects */ def blockLocationsFromStorageStatus(storageStatusList: Seq[StorageStatus]) = { - val blockLocationPairs = storageStatusList - .flatMap(s => s.blocks.map(b => (b._1, s.blockManagerId.hostPort))) + val blockLocationPairs = storageStatusList + .flatMap(s => s.blocks.map(b => (b._1, s.blockManagerId.hostPort))) blockLocationPairs.groupBy(_._1).map{case (k, v) => (k, v.unzip._2)}.toMap } |