Spark Streaming狀態管理函數（三）—MapWithState的使用（scala版）

文章目錄 關於mapWithState 注意事項 示例代碼 運行 結論 關於mapWithState   須要本身寫一個匿名函數func來實現本身想要的功能。若是有初始化的值得須要，可使用initialState(RDD)來初始化key的值。 另外，還能夠指定timeout函數，該函數的做用是，若是一個key超過timeout設定的時間沒有更新值，那麼這個key將會失效。這個控制須要在func中實

>>阅读原文<<