Scala: Merge map

by

Using the standard lib, you can do it as follows:

// convert maps to seq, to keep duplicate keys and concat
val merged = Map(1 -> 2).toSeq ++ Map(1 -> 4).toSeq
// merged: Seq[(Int, Int)] = ArrayBuffer((1,2), (1,4))

// group by key
val grouped = merged.groupBy(_._1)
// grouped: scala.collection.immutable.Map[Int,Seq[(Int, Int)]] = Map(1 -> ArrayBuffer((1,2), (1,4)))


// remove key from value set and convert to list
val cleaned = grouped.mapValues(_.map(_._2).toList)
// cleaned: scala.collection.immutable.Map[Int,List[Int]] = Map(1 -> List(2, 4))

More Related Contents:

  1. Best way to merge two maps and sum the values of same key?
  2. Confused with the for-comprehension to flatMap/Map transformation
  3. Scala: Why mapValues produces a view and is there any stable alternatives?
  4. Functional programming, Scala map and fold left [closed]
  5. What are Scala context and view bounds?
  6. (Why) do we need to call cache or persist on a RDD
  7. Return in Scala
  8. Difference between reduce and foldLeft/fold in functional programming (particularly Scala and Scala APIs)?
  9. Abort early in a fold
  10. How to pass -D parameter or environment variable to Spark job?
  11. Generating a class from string and instantiating it in Scala 2.10
  12. Why is “Unable to find encoder for type stored in a Dataset” when creating a dataset of custom case class?
  13. Append a column to Data Frame in Apache Spark 1.3
  14. Scala currying vs partially applied functions
  15. Mixing in a trait dynamically
  16. How to change setting inside SBT command?
  17. Function returns an empty List in Spark
  18. Scala: Implicit parameter resolution precedence
  19. Operate on neighbor elements in RDD in Spark
  20. Renaming column names of a DataFrame in Spark Scala
  21. Difference between fold and foldLeft or foldRight?
  22. Get TypeTag[A] from Class[A]
  23. In Scala, what exactly does ‘val a: A = _’ (underscore) mean?
  24. Spark: long delay between jobs
  25. How do I parse command line arguments in Scala? [closed]
  26. Is there an equivalent to SuppressWarnings in Scala?
  27. Why isn’t Validation a Monad?
  28. How is this case class match pattern working?
  29. Why does one select Scala type members with a hash instead of a dot?
  30. Is it possible to have tuple assignment to variables in Scala? [duplicate]

Leave a Comment