2016-04-14 21 views
0

私は次の操作を行う必要がありますいくつかのStringプロパティによって、私の記録 検索最大[文字列、セット[のMyStuff]

  • が取得大きすぎる
  • 廃棄グループ

    • グループをここで残りのグループ

    のそれぞれで最大の要素は、私がこれまでに得たものである:

    val records: TypedPipe[MyStuff] = ... 
    records 
        .groupBy(_.getThatStringProperty) 
        .toSet 
        .filter(_._2.size < 10) 
        .... 
    

    私はUnsortedGrouped[String, Set[MyStuff]]になります。エレガントで、並列化可能で、最小限のメモリ要件で、各グループの「最大」MyStuffを見つけるにはどうすればよいですか?

  • 答えて

    0

    .mapValues { _.max } do