Spark系列--Spark Streaming(八)累加器和廣播變量

累加器(Accumulators)和廣播變量(Broadcast variables)不能從Spark Streaming的檢查點中恢復。若是你啓用檢查並也使用了累加器和廣播變量，那麼你必須建立累加器和廣播變量的延遲單實例從而在驅動因失效重啓後他們能夠被從新實例化。以下例述：python object WordBlacklist { @volatile private var instanc

>>阅读原文<<