object WordBlacklist { @volatile private var instance: Broadcast[Seq[String]] = null def getInstance(sc: SparkContext): Broadcast[Seq[String]] = { if (instance == null) { synchronized { if (instance == null) { val wordBlacklist = Seq("a", "b", "c") instance = sc.broadcast(wordBlacklist) } } } instance } }
no subject
Date: 2017-02-06 11:04 pm (UTC)no subject
Date: 2017-02-06 11:08 pm (UTC)http://spark.apache.org/docs/latest/streaming-programming-guide.html#accumulators-broadcast-variables-and-checkpoints
no subject
Date: 2017-02-06 11:57 pm (UTC)no subject
Date: 2017-02-06 11:59 pm (UTC)no subject
Date: 2017-02-07 12:22 am (UTC)и volatile и synchronized страшно как то - я вообще не помню что бы мне такой код приходилось писать, в прочем я обычная макака клавиатурная и могу многого не знать