Hi, I have a DStream I'd like to collect and broadcast it's values. To do so I've created a mutable HashMap which i'm filling with foreachRDD but when I'm checking it, it remains empty. If I use ArrayBuffer it works as expected.
This is my code: val arr = scala.collection.mutable.HashMap.empty[String,String] MappedVersionsToBrodcast.foreachRDD(r=> { r.foreach(r=> { arr+=r}) } ) What am I missing here? Thank you, Daniel