SparkStreaming——实例3：带状态操作

带状态操作，updateStateByKey 实例1、实例2只是把这5s中产生的数据wordcount，也就是每5s统计一次这5s的数据， 而如果我们需要统计从一开始到现在产生的数据，就需要updateStateByKey   updateStateByKey操作，可以让我们为每个key维护一份state，并持续不断的更新该state。 1、首先，要定义一个state，可以是任意的数据类型； 2、

>>阅读原文<<