Spark Streaming状态管理函数（三）—MapWithState的使用（scala版）

文章目录 关于mapWithState 注意事项 示例代码 运行 结论 关于mapWithState   须要本身写一个匿名函数func来实现本身想要的功能。若是有初始化的值得须要，可使用initialState(RDD)来初始化key的值。 另外，还能够指定timeout函数，该函数的做用是，若是一个key超过timeout设定的时间没有更新值，那么这个key将会失效。这个控制须要在func中实

>>阅读原文<<