1

我正在尝试在我分组的集合中进行简单的聚合。像这样：

case class Foo(key:String, value:Int)
val minPerKey = lotsOfFoos.groupBy(_.key).mapValues(_.minBy(_.value))

现在我想并行执行相同的操作，但 ParMap 没有 mapValues 函数。

为什么会这样，我应该怎么做？

4

2 回答 2

3

Scala 2.10 具有用于 ParMap 的 mapValues。

但是将 mapValues 与 ParMap 一起使用并没有太多好处。mapValues 方法只是为您提供了一个在读取值时应用您的函数的新 Map，它实际上并没有更改 Map 中的值。因此，您需要执行一些其他操作来强制使用映射值创建新 Map。

于 2013-01-24T20:48:53.520 回答
1

由于 ParMapLike 上不存在 mapValues，因此剩下两个选项：

  1. 只需使用地图：.map{case (key, value) => (key->value.minBy(_.value)) }
  2. 走出平行宇宙：.toMap.mapValues(_.minBy(_.value))

我不知道为什么 mapValues 不仅仅在 ParMapLike 上实现

于 2013-01-24T20:35:27.887 回答