阅读背景:

利用mapWithState实现按照首字母统计的有状态的wordCount

来源:互联网 

最近在做sparkstreaming整合kafka的时候遇到了一个问题:

可以抽象成这样一个问题:有状况的wordCount,且依照word的第一个字母为key,但是请求输出的格局为(word,1)这样的情势可以抽象成这样一个问题:有




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: